You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
62 lines
1.7 KiB
62 lines
1.7 KiB
14 years ago
|
<?php
|
||
|
|
/**
|
||
|
|
*
|
||
|
|
* Copyright (C) 2009 Progress Software, Inc. All rights reserved.
|
||
|
|
* http://fusesource.com
|
||
|
|
*
|
||
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||
|
|
* you may not use this file except in compliance with the License.
|
||
|
|
* You may obtain a copy of the License at
|
||
|
|
*
|
||
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||
|
|
*
|
||
|
|
* Unless required by applicable law or agreed to in writing, software
|
||
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||
|
|
* See the License for the specific language governing permissions and
|
||
|
|
* limitations under the License.
|
||
|
|
*/
|
||
|
|
/*
|
||
|
|
To successfully run this example, you must first start the broker with stomp+ssl enabled.
|
||
|
|
You can do that by executing:
|
||
|
|
$ ${ACTIVEMQ_HOME}/bin/activemq xbean:activemq-connectivity.xml
|
||
|
|
Then you can execute this example with:
|
||
|
|
$ php connectivity.php
|
||
|
|
*/
|
||
|
|
// include a library
|
||
|
|
#require_once("Stomp.php");
|
||
|
|
// make a connection
|
||
|
|
try
|
||
|
|
{
|
||
|
|
$con = new Stomp("tcp://localhost:61613");
|
||
|
|
// connect
|
||
|
|
#$con->connect();
|
||
|
|
#// send a message to the queue
|
||
|
|
#$con->send("/topic/fedora.apim.update", "test");
|
||
|
|
#echo "Sent message with body 'test'\n";
|
||
|
|
// subscribe to the queue
|
||
|
|
$con->subscribe("/queue/fedora.apim.update");
|
||
|
|
// receive a message from the queue
|
||
|
|
while (true)
|
||
|
|
{
|
||
|
|
$msg = $con->readFrame();
|
||
|
|
// do what you want with the message
|
||
|
|
if ( $msg != null) {
|
||
|
|
$con->ack($msg);
|
||
|
|
echo "Received message with body '$msg->body'\n";
|
||
|
|
// mark the message as received in the queue
|
||
|
|
var_dump($msg->headers['pid']);
|
||
|
|
} else {
|
||
|
|
echo "Failed to receive a message\n";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// disconnect
|
||
|
|
#$con->disconnect();
|
||
|
|
} catch (StompException $e)
|
||
|
|
{
|
||
|
|
echo "StompException!";
|
||
|
|
var_dump($e);
|
||
|
|
}
|
||
|
|
?>
|