lib/logjam_agent/request.rb in logjam_agent-0.26.2 vs lib/logjam_agent/request.rb in logjam_agent-0.26.3

@@ -18,9 +18,15 @@
       @fields = initial_fields.merge(:request_id => @uuid, :host => LogjamAgent.hostname,
                                      :process_id => Process.pid, :lines => @lines)
       unless (revision = LogjamAgent.application_revision).blank?
         @fields[:revision] = revision
       end
+      if ENV['CLUSTER']
+        @fields[:cluster] = ENV['CLUSTER']
+      end
+      if ENV['DATACENTER']
+        @fields[:datacenter] = ENV['DATACENTER']
+      end
       if start_time = @fields.delete(:start_time)
         self.start_time = start_time
       end
       @mutex = Mutex.new
       @ignored = false