Merge pull request #43 from nickethier/master

Quick fix for AMQP output (LOGSTASH-151)
This commit is contained in:
Jordan Sissel 2011-08-19 00:06:08 -07:00
commit 3a160f5add

View file

@ -94,7 +94,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
public
def receive(event)
key = event.sprintf(@key)
key = event.sprintf(@key) if @key
@logger.debug(["Sending event", { :destination => to_s, :event => event, :key => key }])
begin
if @target