lib/logstash/outputs/redis.rb in logstash-output-redis-2.0.0 vs lib/logstash/outputs/redis.rb in logstash-output-redis-2.0.1

@@ -138,10 +138,10 @@
 
     @congestion_check_times = Hash.new { |h,k| h[k] = Time.now.to_i - @congestion_interval }
   end # def register
 
   def receive(event)
-    return unless output?(event)
+    
 
     if @batch and @data_type == 'list' # Don't use batched method for pubsub.
       # Stud::Buffer
       buffer_receive(event.to_json, event.sprintf(@key))
       return