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