def _dispatcher(self, xs):
        cb = self.factory.client.getObserver("/%s" % xs.name)
        
        cb(self, xs)
Encode request into client_message
dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py/XmlStreamJabber._dispatcher--crossover with--dataset/ETHPy150Open hazelcast/hazelcast-python-client/hazelcast/protocol/codec/topic_add_message_listener_codec.py/encode_request