diff options
| -rw-r--r-- | lib/stompqueuemanager.php | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php index 06be2ba85..4cefba113 100644 --- a/lib/stompqueuemanager.php +++ b/lib/stompqueuemanager.php @@ -108,7 +108,10 @@ class StompQueueManager $this->con->ack($frame); } else { $this->_log(LOG_WARNING, 'Failed handling notice '. $notice->id .' posted at ' . $frame->headers['created'] . ' in queue '. $queue); - // Don't ack; it'll get re-sent + // FIXME we probably shouldn't have to do + // this kind of queue management ourselves + $this->con->ack($frame); + $this->enqueue($notice, $queue); } unset($notice); } |