diff --git a/logstash/handler_amqp.py b/logstash/handler_amqp.py
index ad984db..c8ca4ec 100644
--- a/logstash/handler_amqp.py
+++ b/logstash/handler_amqp.py
@@ -7,6 +7,11 @@
 import pika
 from logstash import formatter
 
+class PikaLogFilter(Filter):
+  """A log filter which filters out pika logs"""
+  def filter(self, record):
+    return not record.name.split(".")[0] == "pika"
+    
 
 class AMQPLogstashHandler(SocketHandler, object):
     """AMQP Log Format handler
@@ -67,6 +72,7 @@ def __init__(self, host='localhost', port=5672, username='guest',
         self.extra_fields = extra_fields
         self.fqdn = fqdn
         self.facility = facility
+        self.addFilter(PikaLogFilter())
 
     def makeSocket(self, **kwargs):