Module: Vx::Consumer

Extended by:
Consumer
Included in:
Consumer
Defined in:
lib/vx/consumer.rb,
lib/vx/consumer/ack.rb,
lib/vx/consumer/error.rb,
lib/vx/consumer/params.rb,
lib/vx/consumer/publish.rb,
lib/vx/consumer/session.rb,
lib/vx/consumer/testing.rb,
lib/vx/consumer/version.rb,
lib/vx/consumer/subscribe.rb,
lib/vx/consumer/instrument.rb,
lib/vx/consumer/serializer.rb,
lib/vx/consumer/subscriber.rb,
lib/vx/consumer/configuration.rb

Defined Under Namespace

Modules: Ack, ClassMethods, Instrument, Publish, Subscribe, Testing Classes: Configuration, ConnectionDoesNotExistError, ModelIsNotdefined, Params, Serializer, Session, Subscriber

Constant Summary collapse

VERSION = 
"0.2.0"
@@session = 
Session.new
@@configuration = 
Configuration.new

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#_channel ⇒ Object

Returns the value of attribute _channel.



22
23
24
 
# File 'lib/vx/consumer.rb', line 22

def _channel
  @_channel
end

#delivery_info ⇒ Object

Returns the value of attribute delivery_info.



21
22
23
 
# File 'lib/vx/consumer.rb', line 21

def delivery_info
  @delivery_info
end

#properties ⇒ Object

Returns the value of attribute properties.



20
21
22
 
# File 'lib/vx/consumer.rb', line 20

def properties
  @properties
end

Class Method Details

.included(base) ⇒ Object 



24
25
26
27
28
29
30
31
 
# 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

Instance Method Details

#configuration ⇒ Object 



114
115
116
 
# File 'lib/vx/consumer.rb', line 114

def configuration
  @@configuration
end

#configure {|configuration| ... } ⇒ Object

Yields:



110
111
112
 
# File 'lib/vx/consumer.rb', line 110

def configure
  yield configuration
end

#exception_handler(e, env) ⇒ Object 



122
123
124
125
126
127
 
# 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? ⇒ Boolean

Returns:

  • (Boolean) 


102
103
104
 
# File 'lib/vx/consumer.rb', line 102

def live?
  session.live?
end

#session ⇒ Object 



118
119
120
 
# File 'lib/vx/consumer.rb', line 118

def session
  @@session
end

#shutdown ⇒ Object 



98
99
100
 
# File 'lib/vx/consumer.rb', line 98

def shutdown
  session.shutdown
end

#wait_shutdown(timeout = nil) ⇒ Object 



106
107
108
 
# File 'lib/vx/consumer.rb', line 106

def wait_shutdown(timeout = nil)
  session.wait_shutdown(timeout)
end