can't create a durable topic subscribers about stomp-websocket HOT 4 CLOSED

To create a durable subscriber, you must set the client-id header on the connect and a subscription name on the subscribe call.

Which STOMP broker are you using? For ActiveMQ, you must set activemq.subscriptionName to the subscription name (as documented in http://activemq.apache.org/stomp)

from stomp-websocket.

Excellently!Thanks a lot!

from stomp-websocket.

@greezen Can you please show me your code about it?

from stomp-websocket.

@Catechacha
use FuseSource\Stomp\Stomp;

$user = getenv("ACTIVEMQ_USER");
if( !$user ) $user = "admin";

$password = getenv("ACTIVEMQ_PASSWORD");
if( !$password ) $password = "password";

//$headers["client-id"]='das';
$consumer = new Stomp("tcp://192.168.0.101:61613");
$consumer->sync = false;
//$consumer->setReadTimeout(10);
$consumer->clientId = "tt1";

//var_dump($consumer->clientId);exit;
//var_dump($consumer->getSessionId());exit;
if(!$consumer->isConnected()){
echo 'begin';
$consumer->connect($user, $password,array('activemq.subcriptionName'=>'tt1' ));
// subscribe to the topic
$consumer->subscribe("/topic/tt1");
}

// receive a message from the topic
$msg = $consumer->readFrame();

// do what you want with the message
if ( $msg != null) {
echo "Message '$msg->body' received from topic\n";
$consumer->ack($msg);
} else {
echo "Failed to receive a message\n";
}
$consumer->unsubscribe('/topic/tt1');
$consumer->disconnect();

from stomp-websocket.