Я использую компонент ZendQueue https://github.com/zendframework/ZendQueue.
После прочтения моих сообщений я пытаюсь их удалить.
Я использую Queue
объект и Activemq
адаптер.
Я подключаюсь нормально, так как могу получить данные, которые публикую. Код ниже:
$message_iterator = $queue->receive(50,50);
foreach($message_iterator as $MessageObject){
do_somthing($MessageObject->body);
$queue->getAdapter()->deleteMessage($MessageObject);
}
$ queue is \ZendQueue\Queue
$ MessageObject is \ZendQueue\Message
адаптер ZendQueue\Adapter\Activemq
Задача ещё не решена.
Других решений пока нет …