diff --git a/bzz/protocol.go b/bzz/protocol.go
index 34ff87c9ca..d29ffa808c 100644
--- a/bzz/protocol.go
+++ b/bzz/protocol.go
@@ -189,8 +189,10 @@ func (self *bzzProtocol) handle() error {
 	   retrieveRequestMsg        // 0x03
 	   peersMsg                  // 0x04
 	*/
+
 	switch msg.Code {
 	case statusMsg:
+		dpaLogger.Warnf("Status message: %#v", msg)
 		return self.protoError(ErrExtraStatusMsg, "")
 
 	case storeRequestMsg:
@@ -206,6 +208,7 @@ func (self *bzzProtocol) handle() error {
 		if err := msg.Decode(&req); err != nil {
 			return self.protoError(ErrDecode, "->msg %v: %v", msg, err)
 		}
+		dpaLogger.Warnf("Request message: %#v", req)
 		req.peer = peer{bzzProtocol: self}
 		self.netStore.addRetrieveRequest(&req)
 
@@ -275,6 +278,7 @@ func (self *bzzProtocol) handleStatus() (err error) {
 
 // outgoing messages
 func (self *bzzProtocol) retrieve(req *retrieveRequestMsgData) {
+	dpaLogger.Warnf("Request message: %#v", req)
 	p2p.EncodeMsg(self.rw, retrieveRequestMsg, req)
 }
 
diff --git a/p2p/peer.go b/p2p/peer.go
index 273b1e9a41..c81a8444e1 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -299,6 +299,9 @@ func (p *Peer) dispatch(msg Msg, protoDone chan struct{}) (wait bool, err error)
 		// optimization: msg is small enough, read all
 		// of it and move on to the next message
 		buf, err := ioutil.ReadAll(msg.Payload)
+		if len(buf) > 0 {
+			p.Warnf("Received message %x", buf)
+		}
 		if err != nil {
 			return false, err
 		}