jgraichen / msgr Goto Github PK

A Rails-like Messaging Framework.

License: MIT License

Ruby 92.04% HTML 7.96%

msgr's Introduction

Msgr: Rails-like Messaging Framework

You know it and you like it. Using Rails you can just declare your routes and create a controller. That's all you need to process requests.

With Msgr you can do the same for asynchronous AMQP messaging. Just define your routes, create your consumer and watch your app processing messages.

Installation

Add this line to your application's Gemfile:

gem 'msgr', '~> 1.5'

And then execute:

bundle

Or install it yourself as:

gem install msgr

Usage

After adding 'msgr' to your Gemfile create a config/rabbitmq.yml like this:

common: &common
  uri: amqp://localhost/

test:
  <<: *common

development:
  <<: *common

production:
  <<: *common

Specify your messaging routes in config/msgr.rb:

route 'local.test.index', to: 'test#index'
route 'local.test.another_action', to: 'test#another_action'

Create your consumer in app/consumers:

class TestConsumer < Msgr::Consumer
  def index
    data = { fuubar: 'abc' }

    publish data, to: 'local.test.another_action'
  end

  def another_action
    puts "#{payload.inspect}"
  end
end

Use Msgr.publish in to publish a message:

class TestController < ApplicationController
  def index
    @data = { abc: 'abc' }

    Msgr.publish @data, to: 'local.test.index'

    render nothing: true
  end
end

Run client daemon with bundle exec msgr.

Advanced configuration

Manual message acknowledgments

Per default messages are automatically acknowledged, if no (n)ack is sent explicitly by the consumer. This can be disabled by setting the auto_ack attribute to false.

class TestConsumer < Msgr::Consumer
  self.auto_ack = false

  def index
    data = { fuubar: 'abc' }

    publish data, to: 'local.test.another_action'
  end
end

Prefetch count

Per default each message queue has a prefetch count of 1. This value can be changed when specifying the messaging routes:

route 'local.test.index', to: 'test#index', prefetch: 42

Testing

Recommended configuration

test:
  <<: *common
  pool_class: Msgr::TestPool
  raise_exceptions: true

The Msgr::TestPool pool implementation executes all consumers synchronously. By enabling the raise_exceptions configuration flag, we can ensure that exceptions raised in a consumer will not be swallowed by dispatcher (which it usually does in order to retry consuming the message).

RSpec example

In your spec_helper.rb:

config.after(:each) do
  # Flush the consumer queue
  Msgr.client.stop delete: true
  Msgr::TestPool.reset
end

In a test:

before { Msgr.client.start }

it 'executes the consumer' do
  # Publish an event on our queue
  Msgr.publish 'payload', to: 'msgr.queue.my_queue'

  # Let the TestPool handle exactly one event
  Msgr::TestPool.run count: 1

  # And finally, assert that something happened
  expect(actual).to eq expected
end

Contributing

Fork it
Create your feature branch (git checkout -b my-new-feature)
Commit your changes (git commit -am 'Add some feature')
Push to the branch (git push origin my-new-feature)
Create new Pull Request

msgr's People

Contributors

Stargazers

Watchers

Forkers

janrenz nicolas-fricke pdcarv soldag

msgr's Issues

Seg fault upon start, when RabbitMQ has to many outstanding messages

My application crashs with a seg fault, when to many messages are in the message queue.
Another gem could be responsible for that, but hence it is caused primarily when Msgr has to consume messages, you better should check it.

My scenario:

responsible service is shut down
another service produces some messages (in my case, 16)
when the service tries to startup afterwards, it is able to consume 5 messages, than crash with the attached error messages

BTW: I had to shorten the output a bit.

Fast Debugger (ruby-debug-ide 0.4.22, debase 0.0.9) listens on 127.0.0.1:60418
--PATH--/client/xikolo-notification.gemspec:15: warning: Insecure world writable dir /usr/local in PATH, mode 040777
=> Booting Thin
=> Rails 4.0.2 application starting in development on http://0.0.0.0:3200
=> Run `rails server -h` for more startup options
=> Ctrl-C to shutdown server
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.162927
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.15715
ETHON: performed MULTI
ETHON: started MULTI
Thin web server (v1.6.1 codename Death Proof)
Maximum connections set to 1024
Listening on 0.0.0.0:3200, CTRL+C to stop
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.014331
ETHON: performed MULTI
ETHON: performed MULTI
ETHON: started MULTI
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.015419
ETHON: performed MULTI
ETHON: started MULTI
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.015765
ETHON: performed MULTI
ETHON: performed MULTI
ETHON: started MULTI
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.02393
An error occured on select: 9
ETHON: performed MULTI
Ack message: 1
Dispatch to runner: Msgr::Dispatcher
Dispatch message to worker.
Dispatch message to SocialNetworkingConsumer
Invoke action :friendship_create.
ETHON: started MULTI
   (3.1ms)  BEGIN
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.029569
ETHON: performed MULTI
ETHON: started MULTI
   (9.2ms)  BEGIN
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.022284
ETHON: performed MULTI
  SQL (28.0ms)  INSERT INTO "notifications" ("created_at", "entity_id", "payload", "topic_exchange", "updated_at") VALUES ($1, $2, $3, $4, $5) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:55 UTC +00:00], ["entity_id", "90ba853e-ac0c-4e42-8612-37117a54c08d"], ["payload", "---\n:id: 90ba853e-ac0c-4e42-8612-37117a54c08d\n:user_id: 00000001-3100-4444-9999-000000000002\n:friend_id: 00000001-3100-4444-9999-000000000100\n:user_name: A. Admin\n:friend_name: U_0 Smith\n"], ["topic_exchange", "--EVENT_NAME--"], ["updated_at", Wed, 26 Feb 2014 10:43:55 UTC +00:00]]
  SQL (57.0ms)  INSERT INTO "notifications" ("created_at", "entity_id", "payload", "topic_exchange", "updated_at") VALUES ($1, $2, $3, $4, $5) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:55 UTC +00:00], ["entity_id", "2f11eae5-7ebd-43b1-890d-e6e0a9957328"], ["payload", "---\n:id: 2f11eae5-7ebd-43b1-890d-e6e0a9957328\n:user_id: 00000001-3100-4444-9999-000000000001\n:friend_id: 00000001-3100-4444-9999-000000000101\n:user_name: Kevin Cool\n:friend_name: U_1 Smith\n"], ["topic_exchange", "--EVENT_NAME--"], ["updated_at", Wed, 26 Feb 2014 10:43:55 UTC +00:00]]
   (7.9ms)  COMMIT
   (20.6ms)  COMMIT
   (2.4ms)  BEGIN
   (1.4ms)  BEGIN
   (0.4ms)  BEGIN
  SQL (7.1ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "befa5849-e171-4866-98b2-f173942431cb"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
  SQL (36.0ms)  INSERT INTO "notifications" ("created_at", "entity_id", "payload", "topic_exchange", "updated_at") VALUES ($1, $2, $3, $4, $5) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["entity_id", "b444e52f-2be3-4673-8377-aefe10d5108a"], ["payload", "---\n:id: b444e52f-2be3-4673-8377-aefe10d5108a\n:user_id: 00000001-3100-4444-9999-000000000002\n:friend_id: 00000001-3100-4444-9999-000000000101\n:user_name: A. Admin\n:friend_name: U_1 Smith\n"], ["topic_exchange", "--EVENT_NAME--"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00]]
   (3.8ms)  COMMIT
  SQL (10.5ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "4046d7a2-c00d-480f-b146-244e24d96da9"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
   (2.4ms)  BEGIN
   (3.9ms)  COMMIT
  SQL (1.8ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "befa5849-e171-4866-98b2-f173942431cb"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000101"]]
   (16.9ms)  COMMIT
   (3.8ms)  BEGIN
   (2.0ms)  BEGIN
   (0.8ms)  COMMIT
   (12.6ms)  BEGIN
  SQL (17.1ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "4046d7a2-c00d-480f-b146-244e24d96da9"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000100"]]
   (3.5ms)  COMMIT
  SQL (35.7ms)  INSERT INTO "notifications" ("created_at", "entity_id", "payload", "topic_exchange", "updated_at") VALUES ($1, $2, $3, $4, $5) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["entity_id", "e298e51a-1d43-4973-a229-3fc0e5ecdfd2"], ["payload", "---\n:id: e298e51a-1d43-4973-a229-3fc0e5ecdfd2\n:user_id: 00000001-3100-4444-9999-000000000001\n:friend_id: 00000001-3100-4444-9999-000000000102\n:user_name: Kevin Cool\n:friend_name: U_2 Smith\n"], ["topic_exchange", "--EVENT_NAME--"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00]]
  SQL (18.6ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "c8ffe40f-ae9b-4c2e-b3a3-b37edb027c98"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
   (3.6ms)  COMMIT
   (1.7ms)  COMMIT
   (5.3ms)  BEGIN
  UserSettings Load (8.0ms)  SELECT "user_settings".* FROM "user_settings" WHERE "user_settings"."user_id" = '00000001-3100-4444-9999-000000000002' LIMIT 1
   (6.2ms)  BEGIN
  SQL (1.5ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "c8ffe40f-ae9b-4c2e-b3a3-b37edb027c98"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000101"]]
  UserSettings Load (18.4ms)  SELECT "user_settings".* FROM "user_settings" WHERE "user_settings"."user_id" = '00000001-3100-4444-9999-000000000001' LIMIT 1
   (7.9ms)  COMMIT
  SQL (17.8ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "6de27495-5ccc-47f6-97f2-b28f2a76af9a"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
   (5.7ms)  COMMIT
   (63.4ms)  BEGIN
  UserSettings Load (32.8ms)  SELECT "user_settings".* FROM "user_settings" WHERE "user_settings"."user_id" = '00000001-3100-4444-9999-000000000002' LIMIT 1
   (1.7ms)  BEGIN
  SQL (9.8ms)  INSERT INTO "user_activities" ("created_at", "notification_id", "updated_at", "user_id") VALUES ($1, $2, $3, $4) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "6de27495-5ccc-47f6-97f2-b28f2a76af9a"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000102"]]
   (3.6ms)  BEGIN
   (0.5ms)  BEGIN
   (0.9ms)  COMMIT
  SQL (11.3ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "4046d7a2-c00d-480f-b146-244e24d96da9"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "WebDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
  SQL (8.0ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "c8ffe40f-ae9b-4c2e-b3a3-b37edb027c98"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "WebDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
  SQL (13.0ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "befa5849-e171-4866-98b2-f173942431cb"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "WebDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
   (3.7ms)  COMMIT
   (3.5ms)  COMMIT
  UserSettings Load (2.6ms)  SELECT "user_settings".* FROM "user_settings" WHERE "user_settings"."user_id" = '00000001-3100-4444-9999-000000000001' LIMIT 1
   (0.6ms)  COMMIT
   (6.3ms)  BEGIN
   (3.5ms)  BEGIN
   (0.8ms)  BEGIN
   (35.9ms)  BEGIN
  SQL (7.0ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "4046d7a2-c00d-480f-b146-244e24d96da9"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "EmailDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
  SQL (5.6ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "c8ffe40f-ae9b-4c2e-b3a3-b37edb027c98"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "EmailDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000002"]]
  SQL (7.4ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "befa5849-e171-4866-98b2-f173942431cb"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "EmailDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
  SQL (16.4ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "6de27495-5ccc-47f6-97f2-b28f2a76af9a"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "WebDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
   (4.3ms)  COMMIT
   (4.4ms)  COMMIT
   (3.0ms)  COMMIT
2014-02-26T10:43:56Z 41072 TID-owhz3jh08 INFO: Sidekiq client with redis options {}
   (20.6ms)  COMMIT
Action :friendship_create done.
Action :friendship_create done.
Action :friendship_create done.
   (1.0ms)  BEGIN
Ack message: 2
Ack message: 4
  SQL (2.6ms)  INSERT INTO "delivery_items" ("created_at", "notification_id", "priority", "scheduled_send_date", "type", "updated_at", "user_id") VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING "id"  [["created_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["notification_id", "6de27495-5ccc-47f6-97f2-b28f2a76af9a"], ["priority", 1], ["scheduled_send_date", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["type", "EmailDeliveryItem"], ["updated_at", Wed, 26 Feb 2014 10:43:56 UTC +00:00], ["user_id", "00000001-3100-4444-9999-000000000001"]]
Ack message: 3
   (38.8ms)  COMMIT
Dispatch to runner: Msgr::Dispatcher
Dispatch message to SocialNetworkingConsumer
Invoke action :friendship_create.
ETHON: started MULTI
Dispatch message to worker.
Action :friendship_create done.
Dispatch to runner: Msgr::Dispatcher
Ack message: 5
Dispatch message to SocialNetworkingConsumer
Dispatch message to worker.
Invoke action :friendship_create.
Dispatch to runner: Msgr::Dispatcher
ETHON: started MULTI
Dispatch message to SocialNetworkingConsumer
Invoke action :friendship_create.
ETHON: started MULTI
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.022421
Dispatch message to worker.
Dispatch to runner: Msgr::Dispatcher
Dispatch message to SocialNetworkingConsumer
Invoke action :friendship_create.
ETHON: started MULTI
Dispatch message to worker.
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.07279
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.072737
ETHON:         performed EASY url= response_code=200 return_code=ok total_time=0.076065
ETHON: performed MULTI
ETHON: performed MULTI
ETHON: started MULTI
ETHON: started MULTI
ETHON:         performed EASY url= response_code=200 return_code=got_nothing total_time=0.014804
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:171: [BUG] Segmentation fault
ruby 2.0.0p353 (2013-11-22 revision 43784) [x86_64-darwin13.0.0]

-- Crash Report log information --------------------------------------------
   See Crash Report log file under the one of following:
     * ~/Library/Logs/CrashReporter
     * /Library/Logs/CrashReporter
     * ~/Library/Logs/DiagnosticReports
     * /Library/Logs/DiagnosticReports
   the more detail of.

-- Control frame information -----------------------------------------------
c:0027 p:---- s:0114 e:000113 CFUNC  :multi_perform
c:0026 p:0018 s:0109 e:000108 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:171
c:0025 p:0034 s:0104 e:000103 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:160
c:0024 p:0036 s:0099 e:000098 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:43
c:0023 p:0020 s:0095 e:000094 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/typhoeus-0.6.7/lib/typhoeus/hydra/runnable.rb:21
c:0022 p:0008 s:0091 e:000090 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/typhoeus-0.6.7/lib/typhoeus/hydra/memoizable.rb:51
c:0021 p:0009 s:0088 e:000087 BLOCK  /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/instrumentation/typhoeus.rb:40
c:0020 p:0106 s:0086 e:000085 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/method_tracer.rb:281
c:0019 p:0009 s:0076 e:000075 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/instrumentation/typhoeus.rb:39
c:0018 p:0009 s:0072 e:000071 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/adapter/typhoeus.rb:11
c:0017 p:0022 s:0069 e:000068 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/runner.rb:57
c:0016 p:0009 s:0066 e:000065 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/global.rb:21
c:0015 p:0032 s:0063 e:000062 METHOD --PATH--/app/helpers/consumer_helper.rb:38
c:0014 p:0026 s:0058 e:000057 METHOD --PATH--/app/helpers/social_networking_consumer_helper.rb:6
c:0013 p:0010 s:0051 e:000050 METHOD --PATH--/app/consumers/social_networking_consumer.rb:5
c:0012 p:0077 s:0048 E:002368 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/consumer.rb:19
c:0011 p:0039 s:0043 E:0009b0 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/dispatcher.rb:24
c:0010 p:0009 s:0037 e:000036 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/dispatcher.rb:11
c:0009 p:0021 s:0033 E:0001e8 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/pool.rb:148 [FINISH]
c:0008 p:---- s:0028 e:000027 CFUNC  :public_send
c:0007 p:0032 s:0023 e:000022 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/calls.rb:25
c:0006 p:0025 s:0015 e:000014 METHOD /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/calls.rb:67
c:0005 p:0011 s:0009 e:000008 BLOCK  /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/actor.rb:322
c:0004 p:0050 s:0007 e:000006 BLOCK  /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/actor.rb:416
c:0003 p:0064 s:0005 e:000004 BLOCK  /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/tasks.rb:55
c:0002 p:0042 s:0003 e:000002 BLOCK  /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/tasks/task_fiber.rb:13 [FINISH]
c:0001 p:---- s:0001 e:000000 ------

/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/tasks/task_fiber.rb:13:in `block in create'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/tasks.rb:55:in `block in initialize'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/actor.rb:416:in `block in task'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/actor.rb:322:in `block in handle_message'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/calls.rb:67:in `dispatch'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/calls.rb:25:in `dispatch'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/celluloid-0.15.2/lib/celluloid/calls.rb:25:in `public_send'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/pool.rb:148:in `dispatch'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/dispatcher.rb:11:in `call'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/dispatcher.rb:24:in `dispatch'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/msgr-0.2.0/lib/msgr/consumer.rb:19:in `dispatch'
--PATH--/app/consumers/social_networking_consumer.rb:5:in `friendship_create'
--PATH--/app/helpers/social_networking_consumer_helper.rb:6:in `helper_friendship_create'
--PATH--/app/helpers/consumer_helper.rb:38:in `get_user'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/global.rb:21:in `run'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/runner.rb:57:in `start'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/acfs-0.31.0/lib/acfs/adapter/typhoeus.rb:11:in `start'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/instrumentation/typhoeus.rb:39:in `run_with_newrelic'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/method_tracer.rb:281:in `trace_execution_scoped'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/newrelic_rpm-3.7.2.192/lib/new_relic/agent/instrumentation/typhoeus.rb:40:in `block in run_with_newrelic'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/typhoeus-0.6.7/lib/typhoeus/hydra/memoizable.rb:51:in `run'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/typhoeus-0.6.7/lib/typhoeus/hydra/runnable.rb:21:in `run'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:43:in `perform'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:160:in `run'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:171:in `trigger'
/Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ethon-0.6.2/lib/ethon/multi/operations.rb:171:in `multi_perform'

-- C level backtrace information -------------------------------------------

-- Other runtime information -----------------------------------------------

* Loaded script: --PATH--/bin/rails

* Loaded features:

    0 enumerator.so
    1 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/enc/encdb.bundle
    2 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/enc/trans/transdb.bundle
    3 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/rbconfig.rb
    4 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/compatibility.rb
    5 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/defaults.rb
    6 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/deprecate.rb
    7 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/errors.rb
    8 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/version.rb
    9 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/requirement.rb
   10 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/platform.rb
   11 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/basic_specification.rb
   12 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/stub_specification.rb
   13 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/specification.rb
   14 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/exceptions.rb
   15 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/core_ext/kernel_gem.rb
   16 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/thread.rb
   17 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/monitor.rb
   18 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/core_ext/kernel_require.rb
   19 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems.rb
   20 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/optparse.rb
   21 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/ostruct.rb
   22 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/prettyprint.rb
   23 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/pp.rb
   24 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/stringio.bundle
   25 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/socket.bundle
   26 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/socket.rb
   27 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/debase-0.0.9/lib/debase_internals.bundle
   28 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/debase-0.0.9/lib/debase/version.rb
   29 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/debase-0.0.9/lib/debase/context.rb
   30 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/debase-0.0.9/lib/debase.rb
   31 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/version.rb
   32 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/cgi/core.rb
   33 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/cgi/util.rb
   34 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/cgi/cookie.rb
   35 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/cgi.rb
   36 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/dependency.rb
   37 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/path_support.rb
   38 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/syntax_error.rb
   39 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/psych.bundle
   40 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/node.rb
   41 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/stream.rb
   42 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/document.rb
   43 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/sequence.rb
   44 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/scalar.rb
   45 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/mapping.rb
   46 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes/alias.rb
   47 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/nodes.rb
   48 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/streaming.rb
   49 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/visitor.rb
   50 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/strscan.bundle
   51 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/scalar_scanner.rb
   52 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/to_ruby.rb
   53 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/emitter.rb
   54 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/yaml_tree.rb
   55 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/json/ruby_events.rb
   56 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/json_tree.rb
   57 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors/depth_first.rb
   58 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/visitors.rb
   59 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/handler.rb
   60 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/tree_builder.rb
   61 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/parser.rb
   62 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/omap.rb
   63 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/set.rb
   64 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/coder.rb
   65 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/core_ext.rb
   66 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/date_core.bundle
   67 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/date/format.rb
   68 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/date.rb
   69 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/deprecated.rb
   70 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/stream.rb
   71 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/json/yaml_events.rb
   72 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/json/tree_builder.rb
   73 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/json/stream.rb
   74 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych/handlers/document_stream.rb
   75 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/psych.rb
   76 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/yaml.rb
   77 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/xml_printer.rb
   78 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/interface.rb
   79 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/helper.rb
   80 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/breakpoints.rb
   81 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/catchpoint.rb
   82 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/condition.rb
   83 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/control.rb
   84 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/enable.rb
   85 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/eval.rb
   86 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/frame.rb
   87 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/inspect.rb
   88 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/jump.rb
   89 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/load.rb
   90 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/pause.rb
   91 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/set_type.rb
   92 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/stepping.rb
   93 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/threads.rb
   94 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/commands/variables.rb
   95 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/command.rb
   96 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/ide_processor.rb
   97 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/event_processor.rb
   98 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide.rb
   99 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/multiprocess/pre_child.rb
  100 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/multiprocess/monkey.rb
  101 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/ruby-debug-ide-0.4.22/lib/ruby-debug-ide/multiprocess.rb
  102 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/pathname.bundle
  103 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/pathname.rb
  104 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/user_interaction.rb
  105 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/etc.bundle
  106 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/config_file.rb
  107 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/rubygems_integration.rb
  108 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/shared_helpers.rb
  109 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/fileutils.rb
  110 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/gem_path_manipulation.rb
  111 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/gem_helpers.rb
  112 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/match_platform.rb
  113 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/rubygems_ext.rb
  114 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/version.rb
  115 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler.rb
  116 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/settings.rb
  117 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/digest.bundle
  118 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/digest.rb
  119 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/digest/sha1.bundle
  120 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/set.rb
  121 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/definition.rb
  122 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/dependency.rb
  123 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/ruby_dsl.rb
  124 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/dsl.rb
  125 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/source.rb
  126 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/common.rb
  127 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/generic.rb
  128 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/ftp.rb
  129 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/http.rb
  130 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/https.rb
  131 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/ldap.rb
  132 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/ldaps.rb
  133 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri/mailto.rb
  134 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/uri.rb
  135 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/timeout.rb
  136 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/protocol.rb
  137 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/zlib.bundle
  138 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/exceptions.rb
  139 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/header.rb
  140 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/generic_request.rb
  141 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/request.rb
  142 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/requests.rb
  143 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/response.rb
  144 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/responses.rb
  145 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/proxy_delta.rb
  146 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http/backward.rb
  147 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/net/http.rb
  148 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/time.rb
  149 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/request.rb
  150 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/uri_formatter.rb
  151 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/fcntl.bundle
  152 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/x86_64-darwin13.0.0/openssl.bundle
  153 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/bn.rb
  154 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/cipher.rb
  155 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/config.rb
  156 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/digest.rb
  157 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/x509.rb
  158 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/buffering.rb
  159 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl/ssl.rb
  160 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/openssl.rb
  161 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/securerandom.rb
  162 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/resolv.rb
  163 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/remote_fetcher.rb
  164 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/text.rb
  165 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/name_tuple.rb
  166 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/site_ruby/2.0.0/rubygems/spec_fetcher.rb
  167 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/source/rubygems.rb
  168 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/source/path.rb
  169 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/source/git.rb
  170 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/lockfile_parser.rb
  171 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/lazy_specification.rb
  172 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/tsort.rb
  173 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/forwardable.rb
  174 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/spec_set.rb
  175 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/index.rb
  176 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/environment.rb
  177 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/runtime.rb
  178 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/remote_specification.rb
  179 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/dep_proxy.rb
  180 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/resolver.rb
  181 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/ui.rb
  182 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/endpoint_specification.rb
  183 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353@global/gems/bundler-1.3.5/lib/bundler/setup.rb
  184 --PATH--/config/boot.rb
  185 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe/version.rb
  186 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/delegate.rb
  187 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe/synchronized_delegator.rb
  188 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe.rb
  189 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/array/prepend_and_append.rb
  190 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/hash/deep_merge.rb
  191 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/hash/except.rb
  192 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/hash/slice.rb
  193 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/i18n-0.6.9/lib/i18n/version.rb
  194 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/i18n-0.6.9/lib/i18n/exceptions.rb
  195 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/i18n-0.6.9/lib/i18n/interpolate/ruby.rb
  196 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/i18n-0.6.9/lib/i18n.rb
  197 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/lazy_load_hooks.rb
  198 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/i18n-0.6.9/lib/i18n/config.rb
  199 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/i18n.rb
  200 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe/non_concurrent_cache_backend.rb
  201 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe/mri_cache_backend.rb
  202 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/thread_safe-0.1.3/lib/thread_safe/cache.rb
  203 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/inflector/inflections.rb
  204 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/inflections.rb
  205 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/inflector/methods.rb
  206 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/dependencies/autoload.rb
  207 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/version.rb
  208 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/array/extract_options.rb
  209 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/class/attribute_accessors.rb
  210 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/concern.rb
  211 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/logger_silence.rb
  212 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/logger.rb
  213 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/logger.rb
  214 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support.rb
  215 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/object/blank.rb
  216 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/kernel/singleton_class.rb
  217 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/module/remove_method.rb
  218 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/class/attribute.rb
  219 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/module/delegation.rb
  220 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/singleton.rb
  221 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation/instance_delegator.rb
  222 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/notifications/instrumenter.rb
  223 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/mutex_m.rb
  224 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/notifications/fanout.rb
  225 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/per_thread_registry.rb
  226 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/notifications.rb
  227 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation/behaviors.rb
  228 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation/reporting.rb
  229 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/module/aliasing.rb
  230 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation/method_wrappers.rb
  231 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation/proxy_wrappers.rb
  232 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/module/deprecation.rb
  233 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/deprecation.rb
  234 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/rails.rb
  235 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activesupport-4.0.2/lib/active_support/core_ext/module/attribute_accessors.rb
  236 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/actionpack-4.0.2/lib/action_pack/version.rb
  237 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/actionpack-4.0.2/lib/action_pack.rb
  238 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/tmpdir.rb
  239 /Users/sebastian/.rvm/rubies/ruby-2.0.0-p353/lib/ruby/2.0.0/tempfile.rb
  240 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/rack-1.5.2/lib/rack/multipart.rb
  241 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/rack-1.5.2/lib/rack/utils.rb
  242 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/rack-1.5.2/lib/rack.rb
  243 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/actionpack-4.0.2/lib/action_dispatch.rb
  244 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/rack-1.5.2/lib/rack/server.rb
  245 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/railties-4.0.2/lib/rails/commands/server.rb
  246 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activemodel-4.0.2/lib/active_model/version.rb
  247 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/activemodel-4.0.2/lib/active_model.rb
  248 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/arel-4.0.2/lib/arel/crud.rb
  249 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/arel-4.0.2/lib/arel/factory_methods.rb
  250 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/arel-4.0.2/lib/arel/expressions.rb
  251 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/arel-4.0.2/lib/arel/predications.rb
  252 /Users/sebastian/.rvm/gems/ruby-2.0.0-p353/gems/arel-
....
[NOTE]
You may have encountered a bug in the Ruby interpreter or extension libraries.
Bug reports are welcome.
For details: http://www.ruby-lang.org/bugreport.html


Process finished with exit code 134

Include a bunny-mock gem for testing scenarios

When using msgr and running tests in the host application. Messages will be delivered to the defined RabbitMQ. We should include bunny-mock (https://github.com/scottwb/bunny-mock) to improve testing ...

Split consume and publishing to avoid blocking on backpressure

Use two channels, one for publishing and another for consuming messages. This avoids terminating the consuming channel when a consumer tries to publish a message, but publishing is blocked due to backpressure. With two different channels, only the publishing channel should be blocked, not the consuming one.

Messages on console

In an app which includes msgr, the gem frequently (~30 sec) outputs status messages like:

[STATUS] Idle: 4 Busy: 0

This bloats the console log and should be avoided in development environment.

Messages on console

In an app which includes msgr, the gem frequently (~30 sec) outputs status messages like:

[STATUS] Idle: 4 Busy: 0

This bloats the console log and should be avoided in development environment.

Also, when a message arrives via RabbitMQ, the current output looks like:

Dispatch message to worker.
Dispatch to runner: Msgr::Dispatcher
Dispatch message to CourseConsumer
Invoke action :some_action.
Ack message: 13

Here, it would be nice to first have a notification about the arrived message, maybe something like:

Message received via topic_exchange 'my_topic.exchange' with payload {'payload' => 'dump'}

Then the first two Dispatch-lines would not be necessary.

This would make it much easier to understand the behavior of an app.

Configuration URI problems

Hello. First let me start by saying that this gem is fantastic. It's made integrating RabbitMQ into our Rails project very smooth. That being said I did run in to one problem when setting configuration information.

We're connecting to cloudamqp.com through Heroku and were provided with a preconfigured server, vhost, etc. I'm able to successfully connect to the service using utilities such as Bunny, rabbitmqadmin, etc. while passing each configuration option separately. However when trying to use the URI (amqp://my_user:[email protected]/my_vhost) value in rabbitmq.yml I have no such luck. I receive the following error when trying to connect:

Connection-level error: NOT_ALLOWED - access to vhost '/my_vhost' refused for user 'my_user' (Bunny::NotAllowedError)

It looks like when the config is parsed the :vhost option is set to "/vhost" but I need it to be "vhost" in order to connect.

That being said, would it be possible to provide the configuration details as separate values?

Eg.

# rabbitmq.yml
common: &common
  host: servername
  pass: password
  vhost: vhost
  user: username
...

I'm new to AMQP so please let me know if I'm way off base or if there's anything I can do to correct for this connection problem.

Thanks again for writing such a useful tool!

Msgr does not work with concurrent-ruby 0.6.0

Msgr::Dispatcher requires concurrent/cached_thread_pool which has been renamed.

https://github.com/jdantonio/concurrent-ruby/wiki/Changelog#current-release-v060-25-may-2014

Consumer testing: send test messages

I would like to be able to test my consumers, therefore it would be nice to be able to stub an Msgr::Message, eg via Msgr::Stub::Message.

This would be how I expect a test to look alike:

My msgr.rb routes are defined like this:

route 'myroute.action', to: 'MyConsumer#action'

This is how MyConsumer looks alike:

class MyConsumer < Msgr::Consumer
  def action
    MyModel.create payload
  end
end

And this is how I expect a test to look alike:

describe MyConsumer do
  describe '.action'
    let(:payload) { {id: 1, some_hash: {a: 1, b:2}} }
    let(:message) { Msgr::Stub::Message.new 'myroute.action', payload }

    subject { message.receive }

    it { should change{ MyModel.count }.by 1 }
  end
end

Gem requires symbol config options (:uri) but documentated are string option (uri)

production:
  uri: amqp://your.rabbitmq.host/

does not work, the following is required:

production:
  :uri: amqp://your.rabbitmq.host/

Magr::Route does not support namespaced consumer classes

If a consumer class needs to be namespaced for business reasons, it seems there is currently no way to correctly route it, as Msgr::Route recognizes routing only to consumer_class#action patterns. Namespacing to module_name/consumer_class#action triggers the ArgumentError Must be consumer_class#action.

Send timestamp in properties

RabbitMQ does not transmit the timestamp when a message was published.

In my opinion, it would be very useful to have this set by default as a message property when a message is published via msgr.

The consumer should then be able to access the properties in a easy manner, possibly via accessing a properties hash.

msgr for jruby

When using msgr's gem in jruby environments my service is occupying one core completely.

Can you check the compatibility of msgr with jruby please?

Thanks.

Dependency Dashboard

This issue lists Renovate updates and detected dependencies. Read the Dependency Dashboard docs to learn more.

This repository currently has no open or pending branches.

Detected dependencies

bundler

Gemfile

rake-release '~> 1.1'

rspec '~> 3.0'

github-actions

.github/workflows/test.yml

ruby/setup-ruby v1

ruby/setup-ruby v1

ubuntu 22.04

ubuntu 22.04

Check this box to trigger a request for Renovate to run again on this repository

Dependabot can't parse your Gemfile

Dependabot couldn't parse the Gemfile found at /Gemfile.

You can mention @dependabot in the comments below to contact the Dependabot team.

Recommend Projects

React

A declarative, efficient, and flexible JavaScript library for building user interfaces.
Vue.js

🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
Typescript

TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
TensorFlow

An Open Source Machine Learning Framework for Everyone
Django

The Web framework for perfectionists with deadlines.
Laravel

A PHP framework for web artisans
D3

Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

javascript

JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
web

Some thing interesting about web. New door for the world.
server

A server is a program made to process requests and deliver data to clients.
Machine learning

Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Visualization

Some thing interesting about visualization, use data art
Game

Some thing interesting about game, make everyone happy.

Recommend Org

Facebook

We are working to build community through open source technology. NB: members must have two-factor auth.
Microsoft

Open source projects and samples from Microsoft.
Google

Google ❤️ Open Source for everyone.
Alibaba

Alibaba Open Source for everyone
D3

Data-Driven Documents codes.
Tencent

China tencent open source team.