README

一个用于集成Fusesource Stomp PHP库的Symfony2 bundle。

安装

使用composer安装

php composer.phar require happyr/stomp-bundle

启用bundle

// app/AppKernel.php

public function registerBundles()
{
    $bundles = array(
        // ...
        new HappyR\StompBundle\HappyRStompBundle(),
    );
}

使用服务

//get the connection
$con = $this->container->get('happyr.stomp.broker');

// send a message to the queue
$con->send("/queue/test", "test");
echo "Sent message with body 'test'\n";

// subscribe to the queue
$con->subscribe("/queue/test");

// receive a message from the queue
$msg = $con->readFrame();

// do what you want with the message
if ( $msg != null) {
    echo "Received message with body '$msg->body'\n";

    // mark the message as received in the queue
    $con->ack($msg);
} else {
    echo "Failed to receive a message\n";
}

// disconnect
$con->disconnect();

完整的默认配置

happy_r_stomp:
    borker_uri: tcp://localhost:61613
    client_id: ~

happyr / stomp-bundle

维护者

详情

README

安装

使用服务

完整的默认配置

更多文档