Test helper methods.
Helper for minitest on 1.9
# File test/test_helper.rb, line 53 def caller_method_name parse_caller(caller(2).first).last end
# File test/test_helper.rb, line 159 def checkEmsg(cc) m = cc.poll if m assert m.command != Stomp::CMD_ERROR end end
Subscribe to a destination.
# File test/test_helper.rb, line 145 def conn_subscribe(dest, headers = {}) if @conn.protocol >= Stomp::SPL_11 headers[:id] = @conn.uuid() unless headers[:id] end @conn.subscribe dest, headers end
Get a Stomp Client.
# File test/test_helper.rb, line 99 def get_client() hash = { :hosts => [ {:login => user, :passcode => passcode, :host => host, :port => port}, ], :connect_headers => get_conn_headers(), :stompconn => get_stomp_conn(), :usecrlf => get_crlf(), } client = Stomp::Client.new(hash) client end
Get a connection headers hash.
# File test/test_helper.rb, line 113 def get_conn_headers() ch = {} if ENV['STOMP_TEST11p'] # raise "Invalid 1.1 plus test protocol" if ENV['STOMP_TEST11p'] == Stomp::SPL_10 # if Stomp::SUPPORTED.index(ENV['STOMP_TEST11p']) ch['accept-version'] = ENV['STOMP_TEST11p'] else ch['accept-version'] = Stomp::SPL_11 # Just use 1.1 end # ch['host'] = ENV['STOMP_RABBIT'] ? "/" : host end ch end
Get a Stomp Connection.
# File test/test_helper.rb, line 69 def get_connection() ch = get_conn_headers() hash = { :hosts => [ {:login => user, :passcode => passcode, :host => host, :port => port, :ssl => nil}, ], :reliable => false, :connect_headers => ch, :stompconn => get_stomp_conn(), :usecrlf => get_crlf(), } conn = Stomp::Connection.open(hash) conn end
Determine if tests should rn as line ends
# File test/test_helper.rb, line 138 def get_crlf() ucr = false ucr = true if ENV['STOMP_TEST11p'] && Stomp::SUPPORTED.index(ENV['STOMP_TEST11p']) && ENV['STOMP_TEST11p'] >= Stomp::SPL_12 && ENV['STOMP_CRLF'] ucr end
Get a Stomp SSL Connection.
# File test/test_helper.rb, line 84 def get_ssl_connection() ch = get_conn_headers() ssl_params = Stomp::SSLParams.new(:use_ruby_ciphers => jruby?()) hash = { :hosts => [ {:login => user, :passcode => passcode, :host => host, :port => ssl_port, :ssl => ssl_params}, ], :connect_headers => ch, :stompconn => get_stomp_conn(), :usecrlf => get_crlf(), } conn = Stomp::Connection.new(hash) conn end
Determine if tests should use STOMP instead of CONNECT
# File test/test_helper.rb, line 131 def get_stomp_conn() usc = false usc = true if ENV['STOMP_TEST11p'] && Stomp::SUPPORTED.index(ENV['STOMP_TEST11p']) && ENV['STOMP_TEST11p'] >= Stomp::SPL_11 && ENV['STOMP_CONN'] usc end
Get host
# File test/test_helper.rb, line 38 def host ENV['STOMP_HOST'] || "localhost" end
Check for JRuby before a connection exists
# File test/test_helper.rb, line 167 def jruby?() jr = defined?(RUBY_ENGINE) && RUBY_ENGINE =~ /jruby/ ? true : false end
Get a dynamic destination name.
# File test/test_helper.rb, line 153 def make_destination name = caller_method_name unless name qname = ENV['STOMP_DOTQUEUE'] ? "/queue/test.ruby.stomp." + name : "/queue/test/ruby/stomp/" + name end
Helper for minitest on 1.9
# File test/test_helper.rb, line 58 def parse_caller(at) if /^(.+?):(\d+)(?::in `(.*)')?/ =~ at file = Regexp.last_match[1] line = Regexp.last_match[2].to_i method = Regexp.last_match[3] method.gsub!(" ","_") [file, line, method] end end
Gete passcode
# File test/test_helper.rb, line 33 def passcode ENV['STOMP_PASSCODE'] || "guest" end
Get port
# File test/test_helper.rb, line 43 def port (ENV['STOMP_PORT'] || 61613).to_i end
Generated with the Darkfish Rdoc Generator 2.