Merge pull request #32 from qudos-com/master

allow passing exchange's routing key to amqp handler

Author: vklochan

logstash/handler_amqp.py

@@ -43,8 +43,8 @@ class AMQPLogstashHandler(SocketHandler, object):
     def __init__(self, host='localhost', port=5672, username='guest',
                  password='guest', exchange='logstash', exchange_type='fanout',
                  virtual_host='/', message_type='logstash', tags=None,
-                 durable=False,
-                 version=0, extra_fields=True, fqdn=False, facility=None):
+                 durable=False, version=0, extra_fields=True, fqdn=False,
+                 facility=None, exchange_routing_key=''):
 
 
         # AMQP parameters
@@ -56,7 +56,7 @@ def __init__(self, host='localhost', port=5672, username='guest',
         self.exchange = exchange
         self.exchange_is_durable = durable
         self.virtual_host = virtual_host
-        self.routing_key = ''
+        self.routing_key = exchange_routing_key
 
         SocketHandler.__init__(self, host, port)
 

setup.py

@@ -2,7 +2,7 @@
 setup(
     name='python-logstash',
     packages=['logstash'],
-    version='0.4.4',
+    version='0.4.5',
     description='Python logging handler for Logstash.',
     long_description=open('README.rst').read(),
     author='Volodymyr Klochan',