module Vx::Consumer::ClassMethods

Public Instance Methods

ack() click to toggle source
# File lib/vx/consumer.rb, line 68
def ack
  params.ack = true
end
allocate_pub_channel() { || ... } click to toggle source
# File lib/vx/consumer.rb, line 80
def allocate_pub_channel
  Consumer.session.allocate_pub_channel { yield }
end
configuration() click to toggle source
# File lib/vx/consumer.rb, line 84
def configuration
  Consumer.configuration
end
content_type(value) click to toggle source
# File lib/vx/consumer.rb, line 64
def content_type(value)
  params.content_type = value
end
exchange(*args) click to toggle source
# File lib/vx/consumer.rb, line 38
def exchange(*args)
  params.exchange_options = args.last.is_a?(Hash) ? args.pop : nil
  params.exchange_name    = args.first
end
fanout() click to toggle source
# File lib/vx/consumer.rb, line 43
def fanout
  params.exchange_type = :fanout
end
headers(value) click to toggle source
# File lib/vx/consumer.rb, line 60
def headers(value)
  params.headers = value
end
model(value) click to toggle source
# File lib/vx/consumer.rb, line 72
def model(value)
  params.model = value
end
params() click to toggle source
# File lib/vx/consumer.rb, line 34
def params
  @params ||= Params.new(self.name)
end
queue(*args) click to toggle source
# File lib/vx/consumer.rb, line 51
def queue(*args)
  params.queue_options = args.last.is_a?(Hash) ? args.pop : nil
  params.queue_name    = args.first
end
routing_key(name) click to toggle source
# File lib/vx/consumer.rb, line 56
def routing_key(name)
  params.routing_key = name
end
session() click to toggle source
# File lib/vx/consumer.rb, line 76
def session
  Consumer.session
end
topic() click to toggle source
# File lib/vx/consumer.rb, line 47
def topic
  params.exchange_type = :topic
end
with_middlewares(name, env, &block) click to toggle source
# File lib/vx/consumer.rb, line 88
def with_middlewares(name, env, &block)
  Consumer.configuration.builders[name].to_app(block).call(env)
end