Add persistent:true property to Stomp messages so ActiveMQ doesn't decide to discard them even though persistence is enabled on the broker. :) (Thanks Aric!)

This commit is contained in:
Brion Vibber 2010-01-27 09:24:59 -08:00
parent 7aeb03f727
commit c51539804a
1 changed files with 2 additions and 1 deletions

View File

@ -178,7 +178,8 @@ class StompQueueManager extends QueueManager
$result = $this->con->send($this->queueName($queue),
$msg, // BODY of the message
array ('created' => common_sql_now()));
array ('created' => common_sql_now(),
'persistent' => 'true'));
if (!$result) {
common_log(LOG_ERR, "Error sending $rep to $queue queue");