Create broker with an address + queue 'myqueue' Send a single message to 'myqueue'. Run the following consumer: #!/usr/bin/python3 from __future__ import print_function import optparse from proton.handlers import MessagingHandler from proton.reactor import Container import sys class Recv(MessagingHandler): def __init__(self, url, count): super (Recv, self).__init__(prefetch=0, auto_accept=False) self.url = url self.expected = count self.received = 0 def on_start(self, event): self.receiver = event.container.create_receiver(self.url) self.receiver.flow(1) def on_message(self, event): print( "Received" , event) self.release(event.delivery) self.receiver.flow(1) try : Container(Recv( "amqp: //localhost:5672/myqueue" , 1)).run() except KeyboardInterrupt: pass