diff --git a/src/aleph/db/models/pending_messages.py b/src/aleph/db/models/pending_messages.py
index e68f7fdf..37b51f24 100644
--- a/src/aleph/db/models/pending_messages.py
+++ b/src/aleph/db/models/pending_messages.py
@@ -104,7 +104,7 @@ def from_obj(
             tx_hash=tx_hash,
             reception_time=reception_time,
             fetched=fetched,
-            origin=str(origin),
+            origin=origin,
         )
 
     @classmethod
@@ -142,7 +142,7 @@ def from_message_dict(
             retries=0,
             tx_hash=tx_hash,
             reception_time=reception_time,
-            origin=str(origin),
+            origin=origin,
         )
 
 
diff --git a/src/aleph/services/p2p/protocol.py b/src/aleph/services/p2p/protocol.py
index 6f84bcc3..d52ac169 100644
--- a/src/aleph/services/p2p/protocol.py
+++ b/src/aleph/services/p2p/protocol.py
@@ -26,13 +26,6 @@ async def incoming_channel(
             async for message in p2p_client.receive_messages(topic):
                 try:
                     protocol, topic, peer_id = message.routing_key.split(".")
-                    LOGGER.info(
-                        "Received new %s message on topic %s from %s",
-                        protocol,
-                        topic,
-                        peer_id,
-                    )
-                    LOGGER.info("Received new message %r ", message)
                     LOGGER.debug(
                         "Received new %s message on topic %s from %s",
                         protocol,