Contents

require 'activemq'
require 'qwirk/adapter/active_mq/publisher'
require 'qwirk/adapter/active_mq/worker_config'

puts 'loading active_mq'

::Qwirk.register_adapter(:active_mq, ::Qwirk::Adapter::ActiveMQ::Publisher, ::Qwirk::Adapter::ActiveMQ::WorkerConfig) do |config|
  ::Qwirk::Adapter::JMS::Connection.new(config)
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
qwirk_active_mq_adapter-0.1.1-java	lib/qwirk/adapter/active_mq.rb
qwirk_active_mq_adapter-0.1.0-java	lib/qwirk/adapter/active_mq.rb