def send_message(exchange, routing_key, message, options)
      message_options = options.merge({:routing_key => routing_key})
      message = message.to_json
      EventMachine.next_tick do
        exchange.publish message, message_options
      end
    end
def send_message(exchange, routing_key, message, options)
      message_options = options.merge({:routing_key => routing_key})
      message = message.to_json
      EventMachine.next_tick do
        exchange.publish message, message_options
      end
    end
send a message to an exchange with routing key

 *exchange*:: A AMQP exchange
 *routing_key*:: The routing key to use
 *message*:: The message to be sent
 *options*:: The message options