How to Receive a Message from an Apache ActiveMQ Queue with Pike

import Public.Protocols.Stomp;

int main(int argc, array(string) argv) {
  object c = Client("stomp://localhost:61613");

  c->subscribe("/queue/SampleQueue", lambda(protocol.Frame f) {
      write("%O\n", f->get_body());
    });

  c->set_background();

  return -1;
}
Advertisements

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out /  Change )

Google photo

You are commenting using your Google account. Log Out /  Change )

Twitter picture

You are commenting using your Twitter account. Log Out /  Change )

Facebook photo

You are commenting using your Facebook account. Log Out /  Change )

Connecting to %s

This site uses Akismet to reduce spam. Learn how your comment data is processed.