Updating to amqp version 2.4.2

Author: bakkerd

graypy/rabbitmq.py

@@ -8,7 +8,7 @@
 from logging import Filter
 from logging.handlers import SocketHandler
 
-from amqplib import client_0_8 as amqp  # pylint: disable=import-error
+import amqp  # pylint: disable=import-error
 
 from graypy.handler import BaseGELFHandler
 
@@ -73,7 +73,7 @@ def __init__(self, url, exchange='logging.gelf', exchange_type='fanout',
             **kwargs
         )
         SocketHandler.__init__(self, host, port)
-        self.addFilter(ExcludeFilter('amqplib'))
+        self.addFilter(ExcludeFilter('amqp'))
 
     def makeSocket(self, timeout=1):
         return RabbitSocket(self.cn_args, timeout, self.exchange,
@@ -93,6 +93,7 @@ def __init__(self, cn_args, timeout, exchange, exchange_type, routing_key):
         self.routing_key = routing_key
         self.connection = amqp.Connection(
             connection_timeout=timeout, **self.cn_args)
+        self.connection.connect()
         self.channel = self.connection.channel()
         self.channel.exchange_declare(
             exchange=self.exchange,

setup.py

@@ -66,11 +66,11 @@ def run_tests(self):
         "pylint>=1.9.3,<2.0.0",
         "mock>=2.0.0,<3.0.0",
         "requests>=2.20.1,<3.0.0",
-        "amqplib>=1.0.2,<2.0.0"
+        "amqp>=2.4.2,<2.5.1"
     ],
     extras_require={
         'amqp': [
-            'amqplib==1.0.2'
+            'amqp==2.4.2'
         ],
         "docs": [
             "sphinx>=2.1.2,<3.0.0",