1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
# -*- encoding: utf-8 -*-
#
require 'stomp'
#
# Artemis will summarily close down connections if there is no traffic for some
# time. This code demonstrates running with a gem connetion parameter of
# :reliable => false (the gem will not retry). The code demonstrates handling
# your own retries a certain number of times (3 to be axact).
#
class CliWaiter
@@retry_num = 0
@@max_retries = 3
# Initialize.
def initialize # Change the following as needed.
@gem_retries = false
@host = ENV['STOMP_HOST'] ? ENV['STOMP_HOST'] : "localhost"
@port = ENV['STOMP_PORT'] ? ENV['STOMP_PORT'].to_i : 31613 # Artemis here
@slt = 75
@ver = ENV['STOMP_PROTOCOL'] ? ENV['STOMP_PROTOCOL'] : "1.2"
@hbdata = "0,0" # Force no heartbeats for this example
@conn_hdrs = {"accept-version" => @ver, # version
"host" => "localhost", # vhost
"heart-beat" => @hbdata, # heartbeats
}
@hash = { :hosts => [
{:login => 'guest', :passcode => 'guest', :host => @host, :port => @port},
],
:reliable => @gem_retries, # reliable controls retries by the gem
:autoflush => true,
:connect_headers => @conn_hdrs,
}
p [ "DB1", @hash ]
@do_retry=true # Retry ourself, gem code will not because of :reliable => false
end
# Run example.
def run()
begin
@@retry_num += 1
puts "Try Number: #{@@retry_num}"
puts "Connect host: #{@host}, port: #{@port}"
puts "Connect hash: #{@hash.inspect}"
#
puts "CliWaiter Starts"
c = Stomp::Client.new(@hash)
#
puts "CliWaiter Sleeps: #{@slt} seconds"
sleep @slt
#
c.close
puts "CliWaiter Ends"
rescue Exception => ex
puts "Kaboom, we are in trouble"
puts "Exception Message: #{ex.message}"
puts "Exception Class: #{ex.class}"
puts "The gory details:"
print ex.backtrace.join("\n")
if @do_retry && @@retry_num < @@max_retries
puts "Will retry"
retry
else
puts "Will re-raise"
raise
end
end
end
end
#
#
e = CliWaiter.new()
e.run()
|
