diff --git a/coolamqp/uplink/listener/socket.py b/coolamqp/uplink/listener/socket.py
index 7e2931e1dac1ad4e287a4e691fc4600e57d323c5..29b7000644c5902698eb6e751c27fa826eae0ebb 100644
--- a/coolamqp/uplink/listener/socket.py
+++ b/coolamqp/uplink/listener/socket.py
@@ -3,6 +3,9 @@ from __future__ import absolute_import, division, print_function
 
 import collections
 import socket
+import logging
+
+logger = logging.getLogger(__name__)
 
 
 class SocketFailed(IOError):
@@ -91,6 +94,8 @@ class BaseSocket(object):
         except (IOError, socket.error) as e:
             raise SocketFailed(repr(e))
 
+        logger.debug('Received %s', repr(data))
+
         if len(data) == 0:
             raise SocketFailed('connection gracefully closed')
 
@@ -121,6 +126,7 @@ class BaseSocket(object):
 
             try:
                 sent = self.sock.send(self.data_to_send[0])
+                logger.debug('Sent %s', repr(self.data_to_send[0]))
             except (IOError, socket.error):
                 raise SocketFailed()