Contents

# -*- encoding: utf-8 -*-

require 'rubygems'
require 'stomp'

client = Stomp::Client.new("failover://(stomp://:@localhost:61613,stomp://:@remotehost:61613)?initialReconnectDelay=5000&randomize=false&useExponentialBackOff=false")

puts "Subscribing to /topic/ronaldo"

client.subscribe("/topic/ronaldo") do |msg|
  puts msg.to_s  
  puts "----------------"
end

loop do
  sleep(1)
  puts "."
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
stomp-1.2.4	examples/topic_consumer.rb
stomp-1.2.3	examples/topic_consumer.rb
stomp-1.2.2	examples/topic_consumer.rb
stomp-1.2.1	examples/topic_consumer.rb
stomp-1.2.0	examples/topic_consumer.rb