lib/logjam_agent/request.rb in logjam_agent-0.6.3 vs lib/logjam_agent/request.rb in logjam_agent-0.6.4

@@ -39,21 +39,21 @@
       end
     end
 
     def forward
       engine = @fields.delete(:engine)
-      @forwarder.forward(encode_payload, engine)
+      @forwarder.forward(encode_payload, :engine => engine)
     rescue Exception => e
       handle_forwarding_error(e)
     end
 
     private
 
     if defined?(Oj)
       def encode_payload
         Oj.dump(@fields, :mode => :compat)
       rescue
-        @fields.to_son
+        @fields.to_json
       end
     else
       def encode_payload
         @fields.to_json
       end