lib/killjoy/consumer.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

module Killjoy
  class Consumer
    attr_reader :shard

    def initialize(shard)
      @shard = shard
    end

    def work(message)
      raise "NotImplementedException"
    end

    def bindings
      [queue_name]
    end

    def queue_name
      "sharding: killjoy - rabbit@localhost - #{shard}"
    end
  end
end