Merge pull request #660 from MasoniteFramework/fix-659

closes connections now

masonite/drivers/QueueAmqpDriver.py

@@ -39,6 +39,8 @@ def _publish(self, body):
                                    properties=self.pika.BasicProperties(
                                        delivery_mode=2,  # make message persistent
                                    ))
+        self.channel.close()
+        self.connection.close()
 
     def push(self, *objects, args=(), callback='handle', ran=1, channel=None):
         """Push objects onto the amqp stack.
@@ -89,7 +91,13 @@ def consume(self, channel, fair=False):
 
         if fair:
             self.channel.basic_qos(prefetch_count=1)
-        return self.channel.start_consuming()
+
+        try:
+            self.channel.start_consuming()
+        finally:
+            self.channel.stop_consuming()
+            self.channel.close()
+            self.connection.close()
 
     def work(self, ch, method, properties, body):
         from wsgi import container
@@ -109,10 +117,7 @@ def work(self, ch, method, properties, body):
             except AttributeError:
                 obj(*args)
 
-            try:
-                self.success('[\u2713] Job Successfully Processed')
-            except UnicodeEncodeError:
-                self.success('[Y] Job Successfully Processed')
+            self.success('[\u2713] Job Successfully Processed')
         except Exception as e:
             self.danger('Job Failed: {}'.format(str(e)))
 

masonite/info.py

@@ -1,3 +1,3 @@
 """Module for specifying the Masonite version in a central location."""
 
-VERSION = '2.1.24'
+VERSION = '2.1.25'