Skip to content

Commit 6af9bd0

Browse files
author
DanielePalaia
committed
fix options parameters
1 parent 756f534 commit 6af9bd0

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

rabbitmq_amqp_python_client/consumer.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,13 +62,12 @@ def _create_receiver(self, addr: str) -> BlockingReceiver:
6262
receiver = self._conn.create_receiver(
6363
addr, options=ReceiverOptionUnsettled(addr), handler=self._handler
6464
)
65-
receiver.credit = 1
65+
6666
else:
6767
receiver = self._conn.create_receiver(
6868
addr,
6969
options=ReceiverOptionUnsettledWithFilters(addr, self._stream_options),
7070
handler=self._handler,
7171
)
72-
receiver.credit = 1
7372

7473
return receiver

rabbitmq_amqp_python_client/options.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,11 @@ def __init__(self, addr: str, filter_options: StreamFilterOptions):
7373
self._addr = addr
7474

7575
def apply(self, link: Link) -> None:
76+
link.target.address = self._addr
77+
link.snd_settle_mode = Link.SND_UNSETTLED
78+
link.rcv_settle_mode = Link.RCV_FIRST
79+
link.properties = PropertyDict({symbol("paired"): True})
80+
link.source.dynamic = False
7681
link.source.filter.put_dict(self.filter_set)
7782

7883
def test(self, link: Link) -> bool:

0 commit comments

Comments
 (0)