diff options
| author | Rhenium <rhenium@rhe.jp> | 2013-08-05 09:21:46 +0900 |
|---|---|---|
| committer | Rhenium <rhenium@rhe.jp> | 2013-08-05 09:21:46 +0900 |
| commit | 34501f12ed5f0c028bc7304e7f8260e58c505b01 (patch) | |
| tree | eac2d3f22c35b85410debcc73e39dd105951b4e5 /lib | |
| parent | d1ed18861838e3bb8e42b9f17818e1fb7f9b3d44 (diff) | |
| download | aclog-34501f12ed5f0c028bc7304e7f8260e58c505b01.tar.gz | |
change Account default: enable notification
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/aclog/receiver/collector_connection.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/aclog/receiver/collector_connection.rb b/lib/aclog/receiver/collector_connection.rb index 245a680..30c119c 100644 --- a/lib/aclog/receiver/collector_connection.rb +++ b/lib/aclog/receiver/collector_connection.rb @@ -13,8 +13,8 @@ module Aclog unless defined? @@queue @@queue = EM::Queue.new - _cr = -> bl { bl.call; @@queue.pop &_cr } - EM.defer { @@queue.pop &_cr } + _cr = -> bl { bl.call; @@queue.pop(&_cr) } + EM.defer { @@queue.pop(&_cr) } end end |