W/o Durability
(defmodule activemq_sample (export (main 0))) (defun main () (let ((conn (: stomp connect '"localhost" 61613 '"" '"" )) (f (lambda (msg) (: lfe_io fwrite '"~p~n" (list msg))))) (: stomp subscribe '"/topic/SampleTopic" conn) (: stomp on_message f conn) (: stomp disconnect conn) ) )
W/ Durability
(defmodule activemq_sample (export (main 0))) (defun main () (let ((conn (: stomp connect '"localhost" 61613 '"" '"" (list (tuple '"client-id" '"SampleClient")))) (f (lambda (msg) (: lfe_io fwrite '"~p~n" (list msg))))) (: stomp subscribe '"/topic/SampleTopic2" conn (list (tuple '"activemq.subscriptionName" '"SampleSubscription"))) (: stomp on_message f conn) (: stomp disconnect conn) ) )