diff options
Diffstat (limited to 'lib/killjoy/consumer.rb')
| -rw-r--r-- | lib/killjoy/consumer.rb | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/lib/killjoy/consumer.rb b/lib/killjoy/consumer.rb index 0bb3879..176e658 100644 --- a/lib/killjoy/consumer.rb +++ b/lib/killjoy/consumer.rb @@ -1,10 +1,9 @@ module Killjoy class Consumer - attr_reader :shard, :writers + attr_reader :shard - def initialize(writers, shard) + def initialize(shard) @shard = shard - @writers = writers end def work(message) |
