class CottonTail::DSL::Queue

Queue DSL

Public Class Methods

new(name, queue, context) click to toggle source
# File lib/cotton_tail/dsl/queue.rb, line 7
def initialize(name, queue, context)
  @name = name
  @queue = queue
  @context = context
end

Public Instance Methods

bind(pattern) click to toggle source
# File lib/cotton_tail/dsl/queue.rb, line 23
def bind(pattern)
  return unless @queue.respond_to?(:bind)

  @queue.bind pattern
end
handle(pattern, handler = nil, &block) click to toggle source
# File lib/cotton_tail/dsl/queue.rb, line 13
def handle(pattern, handler = nil, &block)
  bind pattern
  @context.handle(pattern, handler, &block)
end
topic(routing_prefix, &block) click to toggle source
# File lib/cotton_tail/dsl/queue.rb, line 18
def topic(routing_prefix, &block)
  topic = Topic.new(routing_prefix, self)
  topic.instance_eval(&block)
end