Contents

$:.unshift File.join File.dirname(__FILE__), '../lib'
require 'msgr'

Msgr.logger.level = Logger::Severity::INFO

class TestConsumer < Msgr::Consumer
  def index
    log(:info) { payload }
  end

  def another_action
    log(:info) { payload }
  end

  def log_name
    "<TestConsumer##{action}>"
  end
end

#
class NullPool
  def initialize(*)
  end

  def post(*args)
    yield(*args)
  end
end

@client = Msgr::Client.new user: 'guest', password: 'guest',
                           max: 4#, pool_class: NullPool

@client.routes.configure do
  route 'abc.#', to: 'test#index'
  route 'cde.#', to: 'test#index'
  route '#', to: 'test#another_action'
end

@client.start

100.times do |i|
  @client.publish "Message #{i} #{rand}", to: 'abc.XXX'
end

begin
  sleep
rescue Interrupt
ensure
  @client.stop timeout: 10, delete: true
end

$stderr.puts "COUNTER: #{@counter}"

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
msgr-0.11.0.rc2	scripts/simple_test.rb
msgr-0.11.0.rc1	scripts/simple_test.rb