bin/stompcat in stomp-1.2.4 vs bin/stompcat in stomp-1.2.5

- old
+ new

@@ -26,50 +26,50 @@ # Example: stompcat /topic/foo # Would display output that arrives at the /topic/foo stomp destination # begin - if ARGV[0] == '-h' || ARGV[0] == '--help' - $stdout.puts - $stdout.puts 'Usage: stompcat DESTINATION' - $stdout.puts - $stdout.puts 'Receives data from a stomp destination and outputs it to STDOUT' - $stdout.puts - $stdout.puts 'Example: stompcat /topic/foo' - $stdout.puts - $stdout.puts 'Defaults:' - $stdout.puts "DESTINATION\t/topic/default" - $stdout.puts "STOMP_HOST\tlocalhost" - $stdout.puts "STOMP_PORT\t61613" - $stdout.puts "STOMP_USER\t" - $stdout.puts "STOMP_PASSWORD\t" - $stdout.puts - $stdout.puts 'You can override the host, port, user, or password through environment variables' - exit 0 - end + if ARGV[0] == '-h' || ARGV[0] == '--help' + $stdout.puts + $stdout.puts 'Usage: stompcat DESTINATION' + $stdout.puts + $stdout.puts 'Receives data from a stomp destination and outputs it to STDOUT' + $stdout.puts + $stdout.puts 'Example: stompcat /topic/foo' + $stdout.puts + $stdout.puts 'Defaults:' + $stdout.puts "DESTINATION\t/topic/default" + $stdout.puts "STOMP_HOST\tlocalhost" + $stdout.puts "STOMP_PORT\t61613" + $stdout.puts "STOMP_USER\t" + $stdout.puts "STOMP_PASSWORD\t" + $stdout.puts + $stdout.puts 'You can override the host, port, user, or password through environment variables' + exit 0 + end - @port = 61613 - @host = "localhost" - @user = ENV["STOMP_USER"]; - @password = ENV["STOMP_PASSWORD"] + @port = 61613 + @host = "localhost" + @user = ENV["STOMP_USER"]; + @password = ENV["STOMP_PASSWORD"] - @host = ENV["STOMP_HOST"] if ENV["STOMP_HOST"] != nil - @port = ENV["STOMP_PORT"] if ENV["STOMP_PORT"] != nil + @host = ENV["STOMP_HOST"] if ENV["STOMP_HOST"] != nil + @port = ENV["STOMP_PORT"] if ENV["STOMP_PORT"] != nil - @destination = "/topic/default" - @destination = $*[0] if $*[0] != nil + @destination = "/topic/default" + @destination = $*[0] if $*[0] != nil - $stderr.print "Connecting to stomp://#{@host}:#{@port} as #{@user}\n" - @conn = Stomp::Connection.open(@user, @password, @host, @port, true) - $stderr.print "Getting output from #{@destination}\n" + $stderr.print "Connecting to stomp://#{@host}:#{@port} as #{@user}\n" + @conn = Stomp::Connection.open(@user, @password, @host, @port, true) + $stderr.print "Getting output from #{@destination}\n" - @conn.subscribe(@destination, { :ack =>"client" }) - while true - @msg = @conn.receive - $stdout.print @msg.body - $stdout.flush - @conn.ack @msg.headers["message-id"] - end + @conn.subscribe(@destination, { :ack =>"client" }) + while true + @msg = @conn.receive + $stdout.print @msg.body + $stdout.flush + @conn.ack @msg.headers["message-id"] + end rescue end