class ExampleTopicPublisher
Example topic publisher.
Public Class Methods
new()
click to toggle source
Initialize.
# File examples/topic_publisher.rb, line 10 def initialize end
Public Instance Methods
run()
click to toggle source
Run example.
# File examples/topic_publisher.rb, line 13 def run client = Stomp::Client.new("failover://(stomp://:@localhost:61613,stomp://:@remotehost:61613)?initialReconnectDelay=5000&randomize=false&useExponentialBackOff=false") message = "ronaldo #{ARGV[0]}" for i in (1..50) puts "Sending message" client.publish("/topic/ronaldo", "#{i}: #{message}") puts "(#{Time.now})Message sent: #{i}" sleep 0.2 end end