when publishing messages we need to setup unseattle option

Author: DanielePalaia

examples/getting_started/main.py

@@ -70,7 +70,7 @@ def main() -> None:
     exchange_name = "test-exchange"
     queue_name = "example-queue"
     routing_key = "routing-key"
-    messages_to_publish = 100
+    messages_to_publish = 100000
 
     print("connection to amqp server")
     connection = create_connection()
@@ -112,9 +112,9 @@ def main() -> None:
         status = publisher.publish(Message(body="test"))
         if status.ACCEPTED:
             print("message accepted")
-        if status.RELEASED:
+        elif status.RELEASED:
             print("message not routed")
-        if status.REJECTED:
+        elif status.REJECTED:
             print("message not rejected")
 
     publisher.close()

rabbitmq_amqp_python_client/options.py

@@ -21,6 +21,21 @@ def test(self, link: Link) -> bool:
         return bool(link.is_sender)
 
 
+class SenderOptionUnseattle(LinkOption):  # type: ignore
+    def __init__(self, addr: str):
+        self._addr = addr
+
+    def apply(self, link: Link) -> None:
+        link.source.address = self._addr
+        link.snd_settle_mode = Link.SND_UNSETTLED
+        link.rcv_settle_mode = Link.RCV_FIRST
+        link.properties = PropertyDict({symbol("paired"): True})
+        link.source.dynamic = False
+
+    def test(self, link: Link) -> bool:
+        return bool(link.is_sender)
+
+
 class ReceiverOption(LinkOption):  # type: ignore
     def __init__(self, addr: str):
         self._addr = addr

rabbitmq_amqp_python_client/publisher.py

@@ -1,7 +1,7 @@
 import logging
 from typing import Optional
 
-from .options import SenderOption
+from .options import SenderOptionUnseattle
 from .qpid.proton._delivery import Delivery
 from .qpid.proton._message import Message
 from .qpid.proton.utils import (
@@ -34,4 +34,4 @@ def close(self) -> None:
             self._sender.close()
 
     def _create_sender(self, addr: str) -> BlockingSender:
-        return self._conn.create_sender(addr, options=SenderOption(addr))
+        return self._conn.create_sender(addr, options=SenderOptionUnseattle(addr))