#!/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() |