Lines Matching full:self
75 handle_MESSAGE_NAME(self, src, ...):
81 def __init__(self, *optargs, **kwargs):
84 def is_done(self):
88 def name(self):
98 def __init__(self, options, queue_maker):
104 self._options = options
105 self._queue_maker = queue_maker
106 self._topics = {}
108 def add_topic(self, topic_name):
109 if topic_name not in self._topics:
110 self._topics[topic_name] = self._queue_maker()
112 def _get_queue_for_topic(self, topic_name):
113 return self._topics[topic_name]
115 def post_message(self, client, topic_name, message_name, *message_args):
120 queue = self._get_queue_for_topic(topic_name)
123 def run_message_loop(self, topic_name, client, delay_secs=None):
128 self._run_loop(topic_name, client, block=True, delay_secs=delay_secs)
130 def run_all_pending(self, topic_name, client):
132 self._run_loop(topic_name, client, block=False, delay_secs=None)
134 def _run_loop(self, topic_name, client, block, delay_secs):
135 queue = self._get_queue_for_topic(topic_name)
142 self._dispatch_message(msg, client)
144 def _dispatch_message(self, message, client):
161 def __init__(self, src, topic_name, message_name, message_args):
162 self.src = src
163 self.topic_name = topic_name
164 self.name = message_name
165 self.args = message_args
167 def dumps(self):
168 return cPickle.dumps(self)
170 def __repr__(self):
172 (self.src, self.topic_name, self.name))
180 def __init__(self, broker, client, run_topic, post_topic):
184 self._broker = broker
185 self._client = client
186 self._post_topic = post_topic
187 self._run_topic = run_topic
191 def run_message_loop(self, delay_secs=None):
192 self._broker.run_message_loop(self._run_topic, self._client, delay_secs)
194 def post_message(self, message_name, *message_args):
195 self._broker.post_message(self._client, self._post_topic,
