#!/usr/bin/env perl
require 'qpid_proton.pm';

my $messenger = qpid::proton::Messenger->new();
$messenger->set_incoming_window(1);
my $message = qpid::proton::Message->new();

my $address = $ARGV[0];
$address = "~0.0.0.0" if !defined $address;
$messenger->subscribe($address);

$messenger->start();

while (true) {
    my $err = $messenger->receive();
    # XXX: no exceptions!
    die $messenger->get_error() if $err < 0;
    $messenger->get($message);
    print "Got: $message\n";
    $messenger->accept();
}

$messenger->stop();