From a00179ccdea118aad571d91f610e66c552d55a19 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Wed, 9 Aug 2017 16:14:06 +0200
Subject: DPD CE: Fix self.sock usage in Adapt

---
 dpd/src/Adapt.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'dpd/src/Adapt.py')

diff --git a/dpd/src/Adapt.py b/dpd/src/Adapt.py
index 3780979..47a5e8a 100644
--- a/dpd/src/Adapt.py
+++ b/dpd/src/Adapt.py
@@ -59,6 +59,7 @@ class Adapt:
         message : str
             The message string that will be sent to the receiver.
         """
+        sock = self._connect()
         logging.info("Send message: %s" % message)
         msg_parts = message.split(" ")
         for i, part in enumerate(msg_parts):
@@ -67,9 +68,9 @@ class Adapt:
             else:
                 f = zmq.SNDMORE
 
-            self.sock.send(part.encode(), flags=f)
+            sock.send(part.encode(), flags=f)
 
-        data = self.sock.recv_multipart()
+        data = sock.recv_multipart()
         logging.info("Received message: %s" % message)
         return data
 
-- 
cgit v1.2.3