1 files changed, 21 insertions, 0 deletions
diff --git a/deps/rabbitmq_stomp/examples/perl/rabbitmq_stomp_rpc_service.pl b/deps/rabbitmq_stomp/examples/perl/rabbitmq_stomp_rpc_service.pl
new file mode 100755
index 0000000000..31e79aea4a
--- /dev/null
+++ b/deps/rabbitmq_stomp/examples/perl/rabbitmq_stomp_rpc_service.pl
@@ -0,0 +1,21 @@
+#!/usr/bin/perl -w
+
+use Net::Stomp;
+
+my $stomp = Net::Stomp->new({hostname=>'localhost', port=>'61613'});
+$stomp->connect({login=>'guest', passcode=>'guest'});
+
+$stomp->subscribe({'destination'=>'/queue/rabbitmq_stomp_rpc_service', 'ack'=>'client'});
+while (1) {
+    print "Waiting for request...\n";
+    my $frame = $stomp->receive_frame;
+    print "Received message, reply_to = " . $frame->headers->{"reply-to"} . "\n";
+    print $frame->body . "\n";
+
+    $stomp->send({destination => $frame->headers->{"reply-to"}, bytes_message => 1,
+                  body => "Got body: " . $frame->body});
+    $stomp->ack({frame=>$frame});
+    last if $frame->body eq 'QUIT';
+}
+
+$stomp->disconnect;