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