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