falsecz
6/4/2013 - 3:50 PM

gistfile1.php

<?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();