Merge pull request #13 from ingresse/feature/confirm-delivery

Arthur Martins · web-flow · commit ec5619802cb1 · 2019-07-29T14:58:02.000-03:00
Confirm delivery
diff --git a/message_queue/__init__.py b/message_queue/__init__.py
@@ -1,4 +1,4 @@
-__version__ = '0.3.3'
+__version__ = '0.3.4'
 
 from message_queue.logger import *
 
diff --git a/message_queue/adapters/amqp_adapter.py b/message_queue/adapters/amqp_adapter.py
@@ -90,6 +90,7 @@ def connect(self):
         try:
             self.connection = pika.BlockingConnection(self._parameters)
             self.channel = self.connection.channel()
+            self.channel.confirm_delivery()
 
             LOGGER.debug('Connected')
 

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-__version__ = '0.3.3'`
	`1`	`+__version__ = '0.3.4'`
`2`	`2`
`3`	`3`	`from message_queue.logger import *`
`4`	`4`