Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of christian.posta@gmail.com
 designates 209.85.215.44 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAArq7TtExbbK87hGYNAsior0YP+aPifb7yL1r7HqLXD306tQLw@mail.gmail.com>
References: 
 <CAArq7TtExbbK87hGYNAsior0YP+aPifb7yL1r7HqLXD306tQLw@mail.gmail.com>
Date: Tue, 16 Jul 2013 15:25:13 -0400
Message-ID: 
 <CAKS7T5P=rZOmqPx_TqSkbZoPRFGZ+ykhJnp2LnRAZo+ctPuQjg@mail.gmail.com>
Subject: Re: trying to consume (remove) a message
From: Christian Posta <christian.posta@gmail.com>
To: "users@activemq.apache.org" <users@activemq.apache.org>
Content-Type: multipart/alternative; boundary=001a1133e95aa242f804e1a5ef27

--001a1133e95aa242f804e1a5ef27
Content-Type: text/plain; charset=ISO-8859-1

Try giving a brief moment between creating your consumers and the call to
receiveNoWait():

            MessageConsumer consumer =
                    session.createConsumer(queue, "JMSMessageID='" +
jmsMessageID + "'");
            Message message = null;
            Thread.sleep(500);
            while ((message = consumer.receiveNoWait()) != null) {
                System.out.println("Consumed > " + message);
            }

Alternatively, use consumer.receive(500)


On Tue, Jul 16, 2013 at 11:10 AM, Leonardo K. Shikida <shikida@gmail.com>wrote:

> Hi
>
> I am trying to remove (consume) a message from the queue, without success.
>
> Here's my code and the output
>
> public boolean remove(String jmsMessageID) throws JMSException{
>
> boolean messageConsumed = false;
>
> Connection connection = null;
> Session session = null;
> try {
> ConnectionFactory connectionFactory =
> this.baseService.getConnectionFactory();
> connection = connectionFactory.createConnection();
> connection.start();
>
> // Create a Session
> session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>
> QueueBrowser browser = session.createBrowser(this.baseService.getQueue());
>    Enumeration<?> messagesInQueue = browser.getEnumeration();
>
>    while (messagesInQueue.hasMoreElements()) {
>     Message queueMessage = (Message) messagesInQueue.nextElement();
>     System.out.println("Enqueued > "+queueMessage.getJMSMessageID());
>    }
>
>    System.out.println("Trying to delete > "+jmsMessageID);
>
> Queue queue = this.baseService.getQueue();
> MessageConsumer consumer =
> session.createConsumer(queue,"JMSMessageID='"+jmsMessageID+"'");
> Message message = null;
> while((message = consumer.receiveNoWait()) != null){
> System.out.println("Consumed > "+message);
> messageConsumed = true;
> }
>
> } finally {
> if (session != null)
> session.close();
> if (connection != null)
> connection.close();
> }
>
> return messageConsumed;
> }
>
> >>>>>>>
>
> Enqueued          >
> ID:7612866413.mydomain.com-58510-1373986917055-5:1:35:1:1
> Enqueued          >
> ID:7612866413.mydomain.com-58510-1373986917055-5:1:61:1:1
> Enqueued          >
> ID:7612866413.mydomain.com-58510-1373986917055-5:1:63:1:1
> Trying to delete  >
> ID:7612866413.mydomain.com-58510-1373986917055-5:1:63:1:1
>
> (never enter into System.out.println("Consumed > "+message);)
>
> Am I missing something here?
>
> []
>
> Leo
>


-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

--001a1133e95aa242f804e1a5ef27--