lib/logjam_agent/request.rb in logjam_agent-0.0.1 vs lib/logjam_agent/request.rb in logjam_agent-0.0.2
- old
+ new
@@ -17,10 +17,11 @@
def add_line(severity, timestamp, message)
@lines << [severity, format_time(timestamp), message]
end
def forward
- @forwarder.send(@fields.to_json)
+ engine = @fields.delete(:engine)
+ @forwarder.send(@fields.to_json, engine)
rescue Exception => e
handle_forwarding_error(e)
end
private