\"\""); die; } $message = new EnvayaSMS_OutgoingMessage(); $message->id = uniqid(""); $message->to = $to; $message->message = $body; $conn = new AMQPConnection($AMQP_SETTINGS['host'], $AMQP_SETTINGS['port'], $AMQP_SETTINGS['user'], $AMQP_SETTINGS['password'], $AMQP_SETTINGS['vhost']); $ch = $conn->channel(); $ch->queue_declare($AMQP_SETTINGS['queue_name'], false, true, false, false); $event = new EnvayaSMS_Event_Send(array($message)); $msg = new AMQPMessage($event->render(), array('content_type' => 'application/json', 'delivery-mode' => 2)); $ch->basic_publish($msg, '', $AMQP_SETTINGS['queue_name']); $ch->close(); $conn->close(); echo "Message {$message->id} added to AMQP queue\n";