Cacher is the code snippet organizer for pro developers

First of all configure the queue connection to have a prefetchSize of one:

self.connection.subscribe(destination=queueName, id=1, ack='client', headers={'consumer.prefetchSize': 1})

Then, pass the connection as an argument into the listener class and ack the message under the on_message method:

 def on_message(self, headers, message):
 self.connection.ack(headers['message-id'], headers['subscription'])