lib/logjam_agent/request.rb in logjam_agent-0.23.0 vs lib/logjam_agent/request.rb in logjam_agent-0.23.1
- old
+ new
@@ -82,10 +82,11 @@
end
def forward
return if @ignored || LogjamAgent.disabled
engine = @fields.delete(:engine)
- @forwarder.forward(@fields, :engine => engine)
+ sync = @fields.delete(:sync)
+ @forwarder.forward(@fields, :engine => engine, :sync => sync)
rescue Exception => e
handle_forwarding_error(e)
end
private