Method: Lolitra::RabbitmqBus#publish

Defined in:
lib/lolitra/rabbitmq_bus.rb

#publish(message) ⇒ Object 



67
68
69
70
 
# File 'lib/lolitra/rabbitmq_bus.rb', line 67

def publish(message)
  #TODO: if exchange channel is closed doesn't log anything
  self.exchange.publish(message.marshall, :routing_key => message.class.message_key, :timestamp => Time.now.to_i)
end