-

Author: ToGoBananas

client_example.py

@@ -10,10 +10,8 @@ def main():
 
     # wait for initialization
     time.sleep(5)  # TODO: extract 'ready' event from thread
-    print(client.emit('event_test'))
-
-    time.sleep(3)
-    print(client.broadcast('event_test'))
+    client.emit('event_test')
+    client.broadcast('event_test')
 
 
 if __name__ == '__main__':

moleculer/client.py

@@ -55,6 +55,12 @@ def broadcast(self, event_name, data=None):
                 queue_name = 'MOL.EVENT.{node_id}'.format(node_id=node_id)
                 self.channel.basic_publish('', queue_name, event_package)
 
+    def call(self):
+        pass
+
+    def dcall(self):
+        pass
+
     def get_emit_candidates(self, event_name):
         service_names = set()
         for node_id, node_info in self.network.NODES.items():