Class: Jp::ThriftConsumer

Inherits:

AbstractConsumer

• Object
• AbstractClient
• AbstractConsumer
• Jp::ThriftConsumer

Defined in:

lib/rb/jp/consumer.rb

Instance Method Summary

• #initialize(queue, base, options = {}, &block) ⇒ ThriftConsumer constructor

  A new instance of ThriftConsumer.

Methods inherited from AbstractConsumer

#poll, #run

Constructor Details

#initialize(queue, base, options = {}, &block) ⇒ ThriftConsumer

Returns a new instance of ThriftConsumer.

# File 'lib/rb/jp/consumer.rb', line 71

def initialize queue, base, options = {}, &block
	super queue, options, &block
	@base = base
	@deserializer = Thrift::Deserializer.new
end