direct_consumer.py creates a local queue, subscribes it to the message queue on the server, reads messages, and prints them out. We start by creating a local client queue using session.incoming():

local_queue_name = "local_queue"
local_queue = session.incoming(local_queue_name)

Next, we subscribe this queue to the server-side queue named message_queue and call start() to begin message delivery:

session.message_subscribe(queue="message_queue", destination=local_queue_name)
local_queue.start()

Finally, we read the messages from the local queue, acknowledging each message so it can be removed from the server-side queue:

final = "That's all, folks!"   # In a message body, signals the last message
content = ""		       # Content of the last message read

message = None
while content != final:
	message = local_queue.get(timeout=10)
	content = message.body          
        session.message_accept(RangedSet(message.id)) # acknowledge message receipt
	print content