Class: AmqpExchangeDecorator

Inherits:

Object

• Object
• AmqpExchangeDecorator

Defined in:

lib/gorgon/amqp_service.rb

Instance Method Summary

• #initialize(exchange) ⇒ AmqpExchangeDecorator constructor

  A new instance of AmqpExchangeDecorator.

• #publish(msg) ⇒ Object

Constructor Details

#initialize(exchange) ⇒ AmqpExchangeDecorator

Returns a new instance of AmqpExchangeDecorator.

# File 'lib/gorgon/amqp_service.rb', line 17

def initialize exchange
  @exchange = exchange
end

Instance Method Details

#publish(msg) ⇒ Object

# File 'lib/gorgon/amqp_service.rb', line 21

def publish msg
  serialized_msg = Yajl::Encoder.encode(msg)
  @exchange.publish serialized_msg
end