W/o Durability
import Public.Protocols.Stomp; int main(int argc, array(string) argv) { object c = Client("stomp://localhost:61613"); c->subscribe("/topic/SampleTopic", lambda(protocol.Frame f) { write("%O\n", f->get_body()); }); c->set_background(); return -1; }
W/ Durability
import Public.Protocols.Stomp; int main(int argc, array(string) argv) { object c = Client("stomp://localhost:61613", (["client-id":"SampleClient"])); c->subscribe("/topic/SampleTopic", lambda(protocol.Frame f) { write("%O\n", f->get_body()); }, 0, 0, (["activemq.subscriptionName":"SampleSubscription"])); c->set_background(); return -1; }