ruby stomp subscriber example with durable topics

ruby_activemq_subscriber

require 'rubygems'
require 'stomp'



client_id = "client-id"
subscription_name = "subName"
topic_name = "topicName"



stomp_params =  {
    :hosts => [
      { :host => "localhost", :port => 61613},
    ],
    :connect_headers => {'client-id' => client_id},

  }


client = Stomp::Client.new stomp_params

client.subscribe "/topic/#{topic_name}", { "ack" => "client", "activemq.subscriptionName" => subscription_name}  do |msg|


  puts "--------------body----------------"
  p msg.body
  puts "--------------headers----------------"
  p msg.headers
  puts "-----end-----"

  client.acknowledge msg
end

client.join