lib/logstasher/log_subscriber.rb in logstasher-0.4.9 vs lib/logstasher/log_subscriber.rb in logstasher-0.5.0

@@ -13,10 +13,10 @@
       data.merge! extract_exception(payload)
       data.merge! extract_custom_fields(payload)
 
       tags = ['request']
       tags.push('exception') if payload[:exception]
-      event = LogStash::Event.new('@fields' => data, '@tags' => tags)
+      event = LogStash::Event.new('@source' => LogStasher.source, '@fields' => data, '@tags' => tags)
       LogStasher.logger << event.to_json + "\n"
     end
 
     def redirect_to(event)
       Thread.current[:logstasher_location] = event.payload[:location]