allow passing exchange's routing key to amqp handler

alibozorgkhan · alibozorgkhan · commit 4f66b8fc38e2 · 2015-05-06T15:47:58.000-07:00
diff --git a/logstash/handler_amqp.py b/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)
 
