Module: AMQP::Boilerplate::Producer::InstanceMethods
- Defined in:
- lib/amqp/boilerplate/producer.rb
Instance Method Summary collapse
-
#publish(&block) ⇒ void
Publishes a message to the exchange.
Instance Method Details
#publish(&block) ⇒ void
This method returns an undefined value.
Publishes a message to the exchange
95 96 97 98 99 100 101 102 103 104 105 106 107 |
# File 'lib/amqp/boilerplate/producer.rb', line 95 def publish(&block) block ||= lambda { AMQP::Boilerplate.logger.debug "[#{self.class}] Message was published" } = send(self.class..to_sym) if AMQP::Boilerplate.logger.debug "[#{self.class}] Publishing message:\n#{}" exchange.publish(, self.class., &block) else AMQP::Boilerplate.logger.debug "[#{self.class}] Not publishing nil message" end end |