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.
61 lines
1.7 KiB
61 lines
1.7 KiB
<?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); |
|
} |
|
?>
|
|
|