<div dir="ltr">Hi,<br><br>we've to switch from zendJobQueue to RabbitMQ (publish via php and consume via python worker).<br>I've read the examples and everything looks good, but i've to check for running jobs and i don't know how...<br><br>In php I've a squence for jobs/messages:<br>$message = new \PhpAmqpLib\Message\AMQPMessage(json_encode(array(<br>    'id'    => $jobID,<br>    'data' => $data,<br>)));<br>$message->set('message_id', $jobID);<br><br>To check for open messages I've this method:<br>private function getRabbitMQJobIsFinished($jobID) {<br>  $result = true;<br>  $connection = new \PhpAmqpLib\Connection\AMQPConnection(...);<br>  $channel = $connection->channel();<br>  $messageData = $channel->basic_get(self::$queue, false);<br>  while (!empty($messageData)) {<br>    $messageID = $messageData->get('message_id');<br>    if ($messageID == $jobID){<br>      $result = false;<br>      break;<br>    }<br>    $messageData = $channel->basic_get(self::$queue, false);<br>  }<br>  return $result;<br>}<br><br>But this didn't work for unacknowledged/work in progress messages.<br><br>Is ist possible to solve this problem with RabbitMQ?<br><br>Thank you a lot for your help.<br><br><br></div>