Module: ConsumerGroup

Defined in:
lib/deimos/ext/routing_defaults.rb

Instance Method Summary collapse

Instance Method Details

#topic=(name, &block) ⇒ Object


66
67
68
69
70
71
72
# File 'lib/deimos/ext/routing_defaults.rb', line 66

def topic=(name, &block)
  k = Matcher.new
  t = super(name)
  k.instance_eval(&block) if block
  DEFAULTS.replay_on(t)
  k.replay_on(t)
end