add fail() method to stompqueuemanager
This commit is contained in:
parent
557418bc1e
commit
2325d934a8
|
@ -126,6 +126,17 @@ class StompQueueManager
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function fail($object, $queue)
|
||||||
|
{
|
||||||
|
$notice = $object;
|
||||||
|
|
||||||
|
// STOMP server will requeue it after a while anyways,
|
||||||
|
// so no need to notify. Just get it out of our little
|
||||||
|
// array
|
||||||
|
|
||||||
|
$this->_clearFrame($notice, $queue);
|
||||||
|
}
|
||||||
|
|
||||||
function _frameKey($notice, $queue)
|
function _frameKey($notice, $queue)
|
||||||
{
|
{
|
||||||
return ((string)$notice->id) . '-' . $queue;
|
return ((string)$notice->id) . '-' . $queue;
|
||||||
|
|
Loading…
Reference in New Issue
Block a user