I am trying to setup a listener for messages send to an ActiveMq Broker from Zend_Queue. My client code in the listener class looks like this

while (1)
      {
                          
                  if ($messages=$this->queue->receive(1))
                  {
                        foreach ($messages as $message)
                        {
                              if (($msg=$message->body) != null)
                              {
                                    //do my processing and then delete the message from queue
                                    $this->queue->deleteMessage($message);
                              }
                        }
                  }
                        
      }

The problem is with the following code in the ZF Supplied ActiveMQ Adapter (happens around lines 208)

   // signal that we are reading
        if ($this->isConnected == 0)
        {
        $frame = $this->_client->createFrame();
        $frame->setCommand('SUBSCRIBE');
        $frame->setHeader('destination', $queue->getName());
        $frame->setHeader('ack','client');
        $this->_client->send($frame);
        $this->isConnected = 1;
        }

When running in a listening mode , this code creates multiple consumers for every call to receive even though there are no messages on the queue. A better way would have been to strip this code from receive into a seperate method (something like checkmessage or getMessageCount..) and call that before calling receive? Also, it would be nice to have a generic listener in the framework itself that just needs the name of a queue/topic and possibly a polling interval and which can invoke predefined code when it receives a message. Thats how most adapters in EAI systems work.

Again, for now I have written my own adapter that works around this. The documentation on this functionality is sparse so raising an Issue just in case I might have missed something.