lib/logstash/outputs/rackspace.rb in logstash-output-rackspace-0.1.4 vs lib/logstash/outputs/rackspace.rb in logstash-output-rackspace-2.0.5
- old
+ new
@@ -52,10 +52,10 @@
@logger.info("Opened connection to rackspace cloud queues")
end # def register
public
def receive(event)
- return unless output?(event)
+
begin
@rackspace_queue.messages.create :body => event, :ttl => @ttl
#@rackspace_queue.messages.create :body => "some data here", :ttl => @ttl
rescue => e