module Vx::Lib::Consumer
Constants
- Params
- VERSION
Attributes
_channel[RW]
delivery_info[RW]
properties[RW]
Public Class Methods
included(base)
click to toggle source
# File lib/vx/lib/consumer.rb, line 25 def self.included(base) base.extend ClassMethods base.extend Publish base.extend Subscribe base.extend Rpc base.send :include, Ack end
Public Instance Methods
configuration()
click to toggle source
# File lib/vx/lib/consumer.rb, line 120 def configuration @@configuration end
configure() { |configuration| ... }
click to toggle source
# File lib/vx/lib/consumer.rb, line 116 def configure yield configuration end
exception_handler(e, env)
click to toggle source
# File lib/vx/lib/consumer.rb, line 128 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/lib/consumer.rb, line 108 def live? session.live? end
session()
click to toggle source
# File lib/vx/lib/consumer.rb, line 124 def session @@session end
shutdown()
click to toggle source
# File lib/vx/lib/consumer.rb, line 104 def shutdown session.shutdown end
wait_shutdown(timeout = nil)
click to toggle source
# File lib/vx/lib/consumer.rb, line 112 def wait_shutdown(timeout = nil) session.wait_shutdown(timeout) end