Contents

include Java
require 'hornetq/server'
require 'hornetq/client'
require 'hornetq/uri'

module HornetQ

  # Netty Class name
  NETTY_CONNECTOR_CLASS_NAME = 'org.hornetq.core.remoting.impl.netty.NettyConnectorFactory'
  NETTY_ACCEPTOR_CLASS_NAME  = 'org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory'
  INVM_CONNECTOR_CLASS_NAME  = 'org.hornetq.core.remoting.impl.invm.InVMConnectorFactory'
  INVM_ACCEPTOR_CLASS_NAME   = 'org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory'

  DEFAULT_NETTY_PORT     = java.lang.Integer.new(5445)
  DEFAULT_DATA_DIRECTORY = './data'

  # Allow override of our included jars so we don't have to keep up with hornetq releases
  def self.require_jar(jar_name)
    if ENV['HORNETQ_HOME']
      require "#{ENV['HORNETQ_HOME']}/lib/#{jar_name}.jar"
    else
      require "hornetq/java/#{jar_name}.jar"
    end
  end

  def self.netty_port(port)
    port ||= DEFAULT_NETTY_PORT
    return java.lang.Integer.new(port)
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
jruby-hornetq-0.2.3.alpha	lib/hornetq.rb
jruby-hornetq-0.2.1.alpha	lib/hornetq.rb