Added a dedicated thread for handling events sent to the endpoint

1 files changed, 1 insertions, 2 deletions

diff --git a/client.py b/client.py
index 9b59617..20dddce 100755
--- a/client.py
+++ b/client.py
@@ -40,7 +40,6 @@ s = component.queryAdapter(conn, endpoint.IEndpoint)
 

 if args.layer is not None:

     print(args.layer)

-    s.queue = Queue()

     s.connect()

     with open(args.layer, "r") as json_file:

         json_data = json_file.read()

@@ -57,7 +56,7 @@ class Conn(Thread):
         Thread.__init__(self)

         self.queue = queue

         self.in_queue = Queue()

-        s.queue = self.in_queue

+        #s.queue = self.in_queue

         s.connect()

 

     def run(self):