consumer implementation

Author: DanielePalaia

rabbitmq_amqp_python_client/__init__.py

@@ -3,19 +3,15 @@
 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 +43,6 @@
     "exchange_address",
     "queue_address",
     "Message",
-
     "Consumer",
     "MessagingHandler",
     "Event",

rabbitmq_amqp_python_client/connection.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/qpid/proton/_utils.py

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