server.rb in rflow-components-http-1.0.0a2

- old
+ new

@@ -31,11 +31,11 @@
         # This is done by inspecting the provenance, specifically the
         # context attribute that we stored originally
         def process_message(input_port, input_port_key, connection, message)
           RFlow.logger.debug { "#{self.class.name}: Received a #{message.data_type_name}" }
           return unless message.data_type_name == 'RFlow::Message::Data::HTTP::Response'
-          my_events = message.provenance.find_all {|processing_event| processing_event.component_instance_uuid == instance_uuid}
+          my_events = message.provenance.find_all {|processing_event| processing_event.component_instance_uuid == uuid}
 
           my_events.each do |processing_event|
             connection_signature_string = processing_event.context.to_s
             if connections[connection_signature_string]
               RFlow.logger.debug { "#{self.class.name}: Found connection for #{connection_signature_string}" }
@@ -66,10 +66,10 @@
 
 
           def process_http_request
             RFlow.logger.debug { "#{self.class.name}: Received HTTP request from #{client_ip}:#{client_port} to #{@server_ip}:#{@server_port} for #{@http_request_uri}" }
 
-            processing_event = RFlow::Message::ProcessingEvent.new(server.instance_uuid, Time.now.utc)
+            processing_event = RFlow::Message::ProcessingEvent.new(server.uuid, Time.now.utc)
 
             request_message = RFlow::Message.new('RFlow::Message::Data::HTTP::Request')
 
             request_message.data.client_ip    = @client_ip
             request_message.data.client_port  = @client_port