Skip to content

Commit 3f1ac5c

Browse files
author
DanielePalaia
committed
removing print
1 parent 5a5b1db commit 3f1ac5c

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

rabbitmq_amqp_python_client/amqp_consumer_handler.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,7 @@ def on_amqp_message(self, event: Event) -> None:
2727
pass
2828

2929
def on_message(self, event: Event) -> None:
30-
print("first level callback")
3130
if "x-stream-offset" in event.message.annotations:
32-
print("setting offset")
3331
self._offset = int(event.message.annotations["x-stream-offset"])
3432
self.on_amqp_message(event)
3533

rabbitmq_amqp_python_client/connection.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,6 @@ def _on_disconnection(self) -> None:
292292
self._publishers[i]._update_connection(self._conn)
293293

294294
for i, consumer in enumerate(self._consumers):
295-
print("reconnecting consumer")
296295
# Update the broken connection and sender in the consumer
297296
self._consumers[i]._update_connection(self._conn)
298297

0 commit comments

Comments
 (0)