consumer implementation

Author: DanielePalaia

examples/getting_started/main.py

@@ -21,6 +21,7 @@ def __init__(self):
     def on_message(self, event: Event):
         print("received message: " + event.message.body)
         self.accept(event.delivery)
+        self.rele
 
     def on_connection_closed(self, event: Event):
         print("connection closed")

examples/getting_started/main.pytmp

@@ -3,19 +3,13 @@
 from .address_helper import exchange_address, queue_address
 from .common import QueueType
 from .connection import Connection
-<<<<<<< HEAD
-=======
 from .consumer import Consumer
->>>>>>> consumer_implementation
 from .entities import (
     BindingSpecification,
     ExchangeSpecification,
 )
 from .management import Management
 from .publisher import Publisher
-
-from .qpid.proton._message import Message
-
 from .qpid.proton._events import Event
 from .qpid.proton._message import Message
 from .qpid.proton.handlers import MessagingHandler
@@ -47,7 +41,6 @@
     "exchange_address",
     "queue_address",
     "Message",
-
     "Consumer",
     "MessagingHandler",
     "Event",

rabbitmq_amqp_python_client/__init__.py

@@ -1,5 +1,4 @@
 import logging
-
 from typing import Optional
 
 from .consumer import Consumer
@@ -39,7 +38,6 @@ def publisher(self, destination: str) -> Publisher:
         publisher = Publisher(self._conn, destination)
         return publisher
 
-
     def consumer(
         self, destination: str, handler: Optional[MessagingHandler] = None
     ) -> Consumer:

rabbitmq_amqp_python_client/connection.py

@@ -527,7 +527,6 @@ def create_receiver(
                 handler=handler or fetcher,
                 options=options,
             ),
-
             handler or fetcher,
             credit=prefetch,
         )