#!/usr/bin/env python
from __future__ import print_function
import sys
from proton import *

messenger = Messenger()
messenger.incoming_window = 1
message = Message()

address = "~0.0.0.0"
if len(sys.argv) > 1:
  address = sys.argv[1]
messenger.subscribe(address)

messenger.start()

while True:
  messenger.recv()
  messenger.get(message)
  print("Got: %s" % message)
  messenger.accept()

messenger.stop()