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