Class: Oujoke::InvoiceQueue::Publisher

Inherits:
Object
  • Object
show all
Includes:
Helper
Defined in:
lib/queue/publisher.rb

Instance Method Summary collapse

Methods included from Helper

#graceful_death, #log, #logp

Instance Method Details

#amqp_send(queue_name, object) ⇒ Object

end run process



12
13
14
15
16
17
18
 
# File 'lib/queue/publisher.rb', line 12

def amqp_send(queue_name, object)
  AMQP.start do
    amq = MQ.new
    amq.queue(queue_name).publish(serialize(object))
    AMQP.stop { EM.stop }
  end
end

#publish(queue_name, object) ⇒ Object

Call process on selected queue



7
8
9
10
 
# File 'lib/queue/publisher.rb', line 7

def publish(queue_name, object)
    amq = MQ.new
    amq.queue(queue_name).publish(serialize(object))
end