modification for testing purpose

Author: DanielePalaia

examples/getting_started/main.py

@@ -10,18 +10,30 @@
     QuorumQueueSpecification,
     exchange_address,
     queue_address,
+    Delivery,
 )
 
 
+
 class MyMessageHandler(MessagingHandler):
 
     def __init__(self):
         super().__init__()
+        self.auto_accept = False
+        self.auto_settle = False
 
     def on_message(self, event: Event):
         print("received message: " + event.message.body)
-        self.accept(event.delivery)
-        self.rele
+
+        dlv = event.delivery
+        #dlv.update(Delivery.REJECTED)
+        dlv.update(Delivery.RELEASED)
+        dlv.settle()
+
+
+        #self.reject(event.delivery)
+        #self.settle(event.delivery, Delivery.REJECTED)
+
 
     def on_connection_closed(self, event: Event):
         print("connection closed")
@@ -71,9 +83,9 @@ def main() -> None:
     publisher.publish(Message(body="test"))
 
     print("purging the queue")
-    messages_purged = management.purge_queue(queue_name)
+    #messages_purged = management.purge_queue(queue_name)
 
-    print("messages purged: " + str(messages_purged))
+    #print("messages purged: " + str(messages_purged))
 
     for i in range(10):
         publisher.publish(Message(body="test"))
@@ -87,7 +99,7 @@ def main() -> None:
     print("unbind")
     management.unbind(bind_name)
 
-    consumer.close()
+    #consumer.close()
     print("delete queue")
     # management.delete_queue(queue_name)
 

rabbitmq_amqp_python_client/__init__.py

@@ -19,6 +19,8 @@
     StreamSpecification,
 )
 
+from .qpid.proton._delivery import Delivery
+
 try:
     __version__ = metadata.version(__package__)
     __license__ = metadata.metadata(__package__)["license"]
@@ -44,4 +46,5 @@
     "Consumer",
     "MessagingHandler",
     "Event",
+    "Delivery",
 ]

rabbitmq_amqp_python_client/qpid/proton/_handlers.py

@@ -247,6 +247,7 @@ class IncomingMessageHandler(Handler, Acking):
     def __init__(
         self, auto_accept: bool = True, delegate: Optional[Handler] = None
     ) -> None:
+        print("auto accept is" + str(auto_accept))
         self.delegate = delegate
         self.auto_accept = auto_accept
 
@@ -265,8 +266,10 @@ def on_delivery(self, event: Event) -> None:
                     dlv.settle()
             else:
                 try:
+                    print("sending on message")
                     self.on_message(event)
                     if self.auto_accept:
+                        print("accepting")
                         dlv.update(Delivery.ACCEPTED)
                         dlv.settle()
                 except Reject:
@@ -711,8 +714,8 @@ class MessagingHandler(Handler, Acking):
     def __init__(
         self,
         prefetch: int = 10,
-        auto_accept: bool = True,
-        auto_settle: bool = True,
+        auto_accept: bool = False,
+        auto_settle: bool = False,
         peer_close_is_error: bool = False,
     ) -> None:
         self.handlers = []