W/o Durability
require 'stomp' conn = Stomp::Connection.new conn.subscribe '/topic/SampleTopic' msg = conn.receive puts msg conn.disconnect
W/ Durability
require 'stomp' conn = Stomp::Connection.new { :hosts => [ { :host => 'localhost', :port => 61613 } ], :connect_headers => { 'client-id' => 'SampleClient' } } conn.subscribe '/topic/SampleTopic', { 'activemq.subscriptionName' => 'SampleSubscription' } msg = conn.receive puts msg conn.disconnect