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 aacd982 commit d9c9073Copy full SHA for d9c9073
rabbitmq_amqp_python_client/consumer.py
@@ -183,9 +183,9 @@ def _create_receiver(self, addr: str) -> BlockingReceiver:
183
184
if isinstance(self._consumer_options, DirectReplyToConsumerOptions):
185
print("Creating dynamic receiver for direct reply-to")
186
- x = self._conn.create_dynamic_receiver(100, handler=self._handler)
187
- x.credit = credit
188
- return x
+ dynamic_receiver = self._conn.create_dynamic_receiver(100, handler=self._handler)
+ dynamic_receiver.credit = credit
+ return dynamic_receiver
189
190
if isinstance(self._consumer_options, StreamConsumerOptions):
191
return self._conn.create_receiver(
0 commit comments