module TestBase

Test helper methods.

Public Instance Methods

caller_method_name() click to toggle source

Helper for minitest on 1.9

# File test/test_helper.rb, line 53
def caller_method_name
  parse_caller(caller(2).first).last
end
checkEmsg(cc) click to toggle source
# File test/test_helper.rb, line 174
def checkEmsg(cc)
  m = cc.poll
  if m
    assert m.command != Stomp::CMD_ERROR
  end
end
conn_subscribe(dest, headers = {}) click to toggle source

Subscribe to a destination.

# File test/test_helper.rb, line 160
def conn_subscribe(dest, headers = {})
  if @conn.protocol >= Stomp::SPL_11
    headers[:id] = @conn.uuid() unless headers[:id]
  end
  @conn.subscribe dest, headers
end
dflt_data_ex() click to toggle source

Exception Data For Default Tests

# File test/test_helper.rb, line 223
def dflt_data_ex()
  [
    {},
    {:hosts => 123},
    {  :hosts => [
      {:login => 'guest', :passcode => 'guest', :host => "localhost", :port => '' , :ssl => false},
      ],
    :reliable => false,
    },
    {  :hosts => [
      {:login => 'guest', :passcode => 'guest', :host => "localhost", :port => -1 , :ssl => false},
      ],
    :reliable => false,
    },
  ]
end
dflt_data_ok() click to toggle source

OK Data For Default Tests

# File test/test_helper.rb, line 187
def dflt_data_ok()
  [
     #
     {  :hosts => [
        {:login => 'guest', :passcode => 'guest', :host => "localhost", :port => 61613, :ssl => false},
        ],
     :reliable => false,
     },
     #
     {  :hosts => [
        {:login => 'guest', :passcode => 'guest', :ssl => false},
        ],
     :reliable => false,
     },
     #
     {  :hosts => [
        {:login => 'guest', :passcode => 'guest', :port => 61613, :ssl => false},
        ],
     :reliable => false,
     },
     #
     {  :hosts => [
        {:login => 'guest', :passcode => 'guest', :host => "localhost" , :ssl => false},
        ],
     :reliable => false,
     },
     #
     {  :hosts => [
        {:login => 'guest', :passcode => 'guest', :host => '' , :ssl => false},
        ],
     :reliable => false,
     },
  ]
end
get_anonymous_connection() click to toggle source

Get a Stomp Anonymous Connection.

# File test/test_helper.rb, line 84
def get_anonymous_connection()
  ch = get_conn_headers()
  hash = { :hosts => [
      {: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
get_client() click to toggle source

Get a Stomp Client.

# File test/test_helper.rb, line 114
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_conn_headers() click to toggle source

Get a connection headers hash.

# File test/test_helper.rb, line 128
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_connection() click to toggle source

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
get_crlf() click to toggle source

Determine if tests should rn as line ends

# File test/test_helper.rb, line 153
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_ssl_connection() click to toggle source

Get a Stomp SSL Connection.

# File test/test_helper.rb, line 99
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
get_stomp_conn() click to toggle source

Determine if tests should use STOMP instead of CONNECT

# File test/test_helper.rb, line 146
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
host() click to toggle source

Get host

# File test/test_helper.rb, line 38
def host
  ENV['STOMP_HOST'] || "localhost"
end
jruby?() click to toggle source

Check for JRuby before a connection exists

# File test/test_helper.rb, line 182
def jruby?()
  jr = defined?(RUBY_ENGINE) && RUBY_ENGINE =~ /jruby/ ? true : false
end
make_destination() click to toggle source

Get a dynamic destination name.

# File test/test_helper.rb, line 168
def make_destination
  name = caller_method_name unless name
  qname = ENV['STOMP_DOTQUEUE'] ? "/queue/test.ruby.stomp." + name : "/queue/test/ruby/stomp/" + name
end
parse_caller(at) click to toggle source

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
passcode() click to toggle source

Gete passcode

# File test/test_helper.rb, line 33
def passcode
  ENV['STOMP_PASSCODE'] || "guest"
end
port() click to toggle source

Get port

# File test/test_helper.rb, line 43
def port
  (ENV['STOMP_PORT'] || 61613).to_i
end
ssl_port() click to toggle source

Get SSL port

# File test/test_helper.rb, line 48
def ssl_port
  (ENV['STOMP_SSLPORT'] || 61612).to_i
end
user() click to toggle source

Get user

# File test/test_helper.rb, line 28
def user
  ENV['STOMP_USER'] || "guest"
end