channel(); echo "Requesting access\n"; $ch->access_request('/data', false, false, true, true); echo "Declaring exchange\n"; $ch->exchange_declare($EXCHANGE, 'direct', false, false, false); //echo "Declaring queue\n"; //$ch->queue_declare($QUEUE); //echo "Binding queue to exchange\n"; //$ch->queue_bind($QUEUE, $EXCHANGE); echo "Creating message\n"; $msg = new AMQPMessage($msg_body, array('content_type' => 'text/plain')); echo "Publishing message\n"; $ch->basic_publish($msg, $EXCHANGE, $QUEUE); //$ch->basic_publish($msg, $EXCHANGE); echo "Closing channel\n"; $ch->close(); echo "Closing connection\n"; $conn->close(); echo "Done.\n"; } catch (Exception $e) { echo 'Caught exception: ', $e->getMessage(); echo "\nTrace:\n" . $e->getTraceAsString(); } ?>