Class: Qwirk::Adapter::JMS::Publisher::MyTaskProducer

Inherits:

Object

Object
Qwirk::Adapter::JMS::Publisher::MyTaskProducer

show all

Defined in:: lib/qwirk/adapter/jms/publisher.rb

Instance Method Summary collapse

#initialize(publisher, reply_queue, task_id, marshaler) ⇒ MyTaskProducer constructor

A new instance of MyTaskProducer.
#send(marshaled_object) ⇒ Object

Constructor Details

#initialize(publisher, reply_queue, task_id, marshaler) ⇒ `MyTaskProducer`

Returns a new instance of MyTaskProducer.

# File 'lib/qwirk/adapter/jms/publisher.rb', line 112

def initialize(publisher, reply_queue, task_id, marshaler)
  @publisher   = publisher
  @reply_queue = reply_queue
  @task_id     = task_id
  @marshaler   = marshaler
end

Instance Method Details

#send(marshaled_object) ⇒ `Object`



119
120
121

# File 'lib/qwirk/adapter/jms/publisher.rb', line 119

def send(marshaled_object)
  @publisher.publish(marshaled_object, @marshaler, @task_id, {})
end