[rabbitmq-discuss] from zendJobQueue to RabbitMQ - Status Problem

[Alvaro Videla]

Hi,

So I completely misread your question.

What do you mean by "check for open messages"?

You want to know the amount of message that are ready to be consumed?
Or the messages that are being processed at the moment by consumers?

Regards,

Alvaro

On Fri, Mar 14, 2014 at 10:48 AM, Alvaro Videla <videlalvaro at gmail.com> wrote:
> Hi,
>
> basic_get is used to get one message at a time, which makes it not optimal.
>
> See the tutorial here on basic_consume:
> http://www.rabbitmq.com/tutorials/tutorial-two-php.html there you can
> read about message acknowledgments as well.
>
> Regards,
>
> Alvaro
>
> On Fri, Mar 14, 2014 at 8:49 AM, Sascha Wojewsky
> <sascha.wojewsky at gmail.com> wrote:
>> Hi,
>>
>> we've to switch from zendJobQueue to RabbitMQ (publish via php and consume
>> via python worker).
>> I've read the examples and everything looks good, but i've to check for
>> running jobs and i don't know how...
>>
>> In php I've a squence for jobs/messages:
>> $message = new \PhpAmqpLib\Message\AMQPMessage(json_encode(array(
>>     'id'    => $jobID,
>>     'data' => $data,
>> )));
>> $message->set('message_id', $jobID);
>>
>> To check for open messages I've this method:
>> private function getRabbitMQJobIsFinished($jobID) {
>>   $result = true;
>>   $connection = new \PhpAmqpLib\Connection\AMQPConnection(...);
>>   $channel = $connection->channel();
>>   $messageData = $channel->basic_get(self::$queue, false);
>>   while (!empty($messageData)) {
>>     $messageID = $messageData->get('message_id');
>>     if ($messageID == $jobID){
>>       $result = false;
>>       break;
>>     }
>>     $messageData = $channel->basic_get(self::$queue, false);
>>   }
>>   return $result;
>> }
>>
>> But this didn't work for unacknowledged/work in progress messages.
>>
>> Is ist possible to solve this problem with RabbitMQ?
>>
>> Thank you a lot for your help.
>>
>>
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>