Merge pull request #45 from mokshaproject/stomp-protocol-debug

Some debug statements.
mokshaproject · Jun 22, 2017 · a9f9ae3 · a9f9ae3
2 parents 3c787aa + 4464dab
commit a9f9ae3
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/moksha.hub/moksha/hub/stomp/protocol.py b/moksha.hub/moksha/hub/stomp/protocol.py
@@ -76,7 +76,9 @@ def subscribe(self, dest, **headers):
         else:
             f.unpack(stomper.subscribe(dest, ack=ack))
         f.headers.update(headers)
-        self.transport.write(f.pack())
+        cmd = f.pack()
+        log.debug(cmd)
+        self.transport.write(cmd)
 
     def connectionMade(self):
         """ Register with stomp server """
@@ -88,6 +90,7 @@ def connectionMade(self):
             cmd = stomper.connect(self.username, self.password, host, interval)
         else:
             cmd = stomper.connect(self.username, self.password)
+        log.debug(cmd)
         self.transport.write(cmd)
 
     def dataReceived(self, data):
@@ -122,5 +125,5 @@ def dataReceived(self, data):
                response = stomper.stomp_11.nack(message_id, subscription, transaction_id)
 
            # Finally, send our response (ACK or NACK) back to the broker.
-           log.debug("StompProtocol response: %r", response)
+           log.debug(response)
            self.transport.write(response)