#!/usr/bin/perl
################################################################################
#
# Basic Example of AnyEvent::STOMP::Client
#
################################################################################
use AnyEvent::STOMP::Client;
my $stomp_client = new AnyEvent::STOMP::Client();
$stomp_client->connect();
$stomp_client->on_connected(
sub {
my $self = shift;
$self->subscribe('/queue/test-destination');
$self->send(
'/queue/test-destination',
{'content-type' => 'text/plain',},
"Hello World!"
);
}
);
$stomp_client->on_message(
sub {
my ($self, undef, $body) = @_;
print "$body\n";
$self->disconnect;
}
);
AnyEvent->condvar->recv;