We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 067b3f2 commit dc85a1fCopy full SHA for dc85a1f
rabbitmq_amqp_python_client/consumer.py
@@ -68,14 +68,14 @@ def _open(self) -> None:
68
def _update_connection(self, conn: BlockingConnection) -> None:
69
self._conn = conn
70
if self._stream_options is None:
71
- print("creating new receiver without stream")
+ logger.debug("creating new receiver without stream")
72
self._receiver = self._conn.create_receiver(
73
self._addr,
74
options=ReceiverOptionUnsettled(self._addr),
75
handler=self._handler,
76
)
77
else:
78
- print("creating new stream receiver")
+ logger.debug("creating new stream receiver")
79
self._stream_options.offset(self._handler.offset - 1) # type: ignore
80
81
0 commit comments