lib/manageiq/messaging/stomp/queue.rb in manageiq-messaging-0.1.3 vs lib/manageiq/messaging/stomp/queue.rb in manageiq-messaging-0.1.4

@@ -33,10 +33,10 @@
               sender = msg.headers['sender']
               message_type = msg.headers['message_type']
               message_body = decode_body(msg.headers, msg.body)
               logger.info("Message received: queue(#{queue_name}), msg(#{payload_log(message_body)}), headers(#{msg.headers})")
 
-              result = yield [ManageIQ::Messaging::ReceivedMessage.new(sender, message_type, message_body, msg)]
+              result = yield [ManageIQ::Messaging::ReceivedMessage.new(sender, message_type, message_body, msg, self)]
               logger.info("Message processed")
 
               correlation_ref = msg.headers['correlation_id']
               if correlation_ref
                 result = result.first if result.kind_of?(Array)