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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
# -*- encoding: utf-8 -*-
if Kernel.respond_to?(:require_relative)
require_relative("test_helper")
else
$:.unshift(File.dirname(__FILE__))
require 'test_helper'
end
=begin
Main class for testing Stomp::Client URL based Logins.
=end
class TestURLLogins < Test::Unit::TestCase
include TestBase
def setup
hostname = host()
portnum = port()
sslpn = ssl_port()
@tdstomp = [
"stomp://guestl:guestp@#{hostname}:#{portnum}",
"stomp://#{hostname}:#{portnum}",
"stomp://@#{hostname}:#{portnum}",
"stomp://f@#$$%^&*()_+=o.o:@#{hostname}:#{portnum}",
'stomp://f@#$$%^&*()_+=o.o::b~!@#$%^&*()+-_=?:<>,.@@' + hostname + ":#{portnum}",
]
@tdfailover = [
"failover://(stomp://#{hostname}:#{portnum})",
"failover://(stomp://#{hostname}:#{portnum})",
"failover://(stomp://#{hostname}:#{portnum})?whatup=doc&coyote=kaboom",
"failover://(stomp://#{hostname}:#{portnum})?whatup=doc",
"failover://(stomp://#{hostname}:#{portnum})?whatup=doc&coyote=kaboom&randomize=true",
'failover://(stomp://f@#$$%^&*()_+=o.o::b~!@#$%^&*()+-_=?:<>,.@@' + "#{hostname}" + ":#{portnum}" + ")",
'failover://(stomp://f@#$$%^&*()_+=o.o::b~!@#$%^&*()+-_=:<>,.@@' + "#{hostname}" + ":#{portnum}" + ")",
'failover://(stomp://f@#$$%^&*()_+=o.o::b~!@#$%^&*()+-_=?:<>,.@@' + "#{hostname}" + ":#{portnum}" + ")?a=b",
'failover://(stomp://f@#$$%^&*()_+=o.o::b~!@#$%^&*()+-_=:<>,.@@' + "#{hostname}" + ":#{portnum}" + ")?c=d&e=f",
"failover://(stomp://usera:passa@#{hostname}:#{portnum})",
"failover://(stomp://usera:@#{hostname}:#{portnum})",
"failover://(stomp://#{hostname}:#{portnum},stomp://#{hostname}:#{portnum})",
"failover://(stomp://usera:passa@#{hostname}:#{portnum},stomp://#{hostname}:#{portnum})",
"failover://(stomp://usera:@#{hostname}:#{portnum},stomp://#{hostname}:#{portnum})",
"failover://(stomp://#{hostname}:#{portnum},stomp://#{hostname}:#{portnum})?a=b&c=d",
"failover://(stomp://#{hostname}:#{portnum},stomp://#{hostname}:#{portnum})?a=b&c=d&connect_timeout=2020",
]
@sslfailover = [
"failover://(stomp+ssl://#{hostname}:#{sslpn})",
"failover://(stomp+ssl://usera:passa@#{hostname}:#{sslpn})",
"failover://(stomp://usera:@#{hostname}:#{portnum},stomp+ssl://#{hostname}:#{sslpn})",
]
@badparms = "failover://(stomp://#{hostname}:#{portnum})?a=b&noequal"
@client = nil
@turdbg = ENV['TURDBG'] || ENV['TDBGALL'] ? true : false
end
def teardown
@client.close if @client && @client.open? # allow tests to close
end
# test stomp:// URLs
def test_0010_stomp_urls()
mn = "test_0010_stomp_urls" if @turdbg
p [ "01", mn, "starts" ] if @turdbg
@tdstomp.each_with_index do |url, ndx|
c = Stomp::Client.new(url)
assert !c.nil?, url
assert c.open?, url
c.close
end
p [ "99", mn, "ends" ] if @turdbg
end
# test failover:// urls - tcp
def test_0020_failover_urls_tcp()
mn = "test_0020_failover_urls_tcp" if @turdbg
p [ "01", mn, "starts" ] if @turdbg
@tdfailover.each_with_index do |url, ndx|
# p [ "xurl", url, "xndx", ndx ]
c = Stomp::Client.new(url)
assert !c.nil?, url
assert c.open?, url
c.close
end
p [ "99", mn, "ends" ] if @turdbg
end
# test failover:// urls - ssl
def test_0030_failover_urls_ssl()
mn = "test_0030_failover_urls_ssl" if @turdbg
p [ "01", mn, "starts" ] if @turdbg
@sslfailover.each_with_index do |url, ndx|
# p [ "sslxurl", url, "sslxndx", ndx ]
c = Stomp::Client.new(url)
assert !c.nil?, url
assert c.open?, url
c.close
end
p [ "99", mn, "ends" ] if @turdbg
end if ENV['STOMP_TESTSSL']
# test failover:// with bad parameters
def test_0040_failover_badparms()
mn = "test_0040_failover_badparms" if @turdbg
p [ "01", mn, "starts" ] if @turdbg
assert_raise(Stomp::Error::MalformedFailoverOptionsError) {
_ = Stomp::Client.new(@badparms)
}
p [ "99", mn, "ends" ] if @turdbg
end
end unless ENV['STOMP_RABBIT']
|
