queue.rb in manageiq-messaging-0.1.1

- old
+ new

@@ -26,9 +26,11 @@
           queue_name, headers = queue_for_subscribe(options)
 
           # for STOMP we can get message one at a time
           subscribe(queue_name, headers) do |msg|
             begin
+              ack(msg) if auto_ack?(options)
+
               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})")
 