Class: Jp::AbstractProducer

Inherits:

AbstractClient

Object
AbstractClient
Jp::AbstractProducer

show all

Defined in:: lib/rb/jp/producer.rb

Direct Known Subclasses

JsonProducer, TextProducer, ThriftProducer

Instance Method Summary collapse

#add(message) ⇒ Object
#initialize(queue, options = {}) ⇒ AbstractProducer constructor

A new instance of AbstractProducer.

Constructor Details

#initialize(queue, options = {}) ⇒ `AbstractProducer`

Returns a new instance of AbstractProducer.



9
10
11

# File 'lib/rb/jp/producer.rb', line 9

def initialize queue, options = {}
	super queue, options
end

Instance Method Details

#add(message) ⇒ `Object`



12
13
14

# File 'lib/rb/jp/producer.rb', line 12

def add message
	@client.add @queue, translate(message)
end