<?php
require 'vendor/autoload.php';
$loop = React\EventLoop\Factory::create();
$factory = new React\Stomp\Factory($loop);
$client = $factory->createClient(array('vhost' => '/', 'login' => 'guest', 'passcode' => 'guest'));
$client
->connect()
->then(function ($client) use ($loop) {
$client->send('/queue/foo', 'le messagexxx' . time(), [
// http://activemq.apache.org/delay-and-schedule-message-delivery.html
'AMQ_SCHEDULED_DELAY' => 100, // delay v ms
'mojeId' => 50 // custom hlavicka
]);
// filtruje se podle jakykoliv hlavicky http://activemq.apache.org/selectors.html
$headers = ['selector' => "mojeId=50"];
$client->subscribeWithAck('/queue/foo', 'client', function ($frame, $ackResolver) use ($client) {
var_dump($frame);
$ackResolver->ack();
}, $headers);
});
$loop->run();