module Vx::Consumer
Constants
- Params
- VERSION
Attributes
_channel[RW]
delivery_info[RW]
properties[RW]
Public Class Methods
included(base)
click to toggle source
# File lib/vx/consumer.rb, line 24 def self.included(base) base.extend ClassMethods base.extend Instrument base.extend Publish base.extend Subscribe base.send :include, Ack base.send :include, Instrument end
Public Instance Methods
configuration()
click to toggle source
# File lib/vx/consumer.rb, line 114 def configuration @@configuration end
configure() { |configuration| ... }
click to toggle source
# File lib/vx/consumer.rb, line 110 def configure yield configuration end
exception_handler(e, env)
click to toggle source
# File lib/vx/consumer.rb, line 122 def exception_handler(e, env) unless env.is_a?(Hash) env = {env: env} end configuration.on_error.call(e, env) end
live?()
click to toggle source
# File lib/vx/consumer.rb, line 102 def live? session.live? end
session()
click to toggle source
# File lib/vx/consumer.rb, line 118 def session @@session end
shutdown()
click to toggle source
# File lib/vx/consumer.rb, line 98 def shutdown session.shutdown end
wait_shutdown(timeout = nil)
click to toggle source
# File lib/vx/consumer.rb, line 106 def wait_shutdown(timeout = nil) session.wait_shutdown(timeout) end