activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: Messages are repetedly sends by the queue..
Date Wed, 13 Jul 2011 07:36:36 GMT
Can you create a test case that reproduces it?

Regards
-- 
Dejan Bosanac - http://twitter.com/dejanb
-----------------
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Wed, Jul 13, 2011 at 7:31 AM, vijayaratha <rathav@wso2.com> wrote:

> Hi,
> I have an issue with activemq 5.4.2 version..
> where QueueBrowser.getEnumeration().next element() retrieves same
> messages..
> any idea on this?
> this was working in 5.3.2. I version
>
> any help regarding this would be helpful..
>
> Thanks
> -ratha..
>
> This is my code segment;
>
>
>   try{
>            con = getReadConnection();
>            session = JMSUtil.createSession(con,jmsSpec11);
>            Destination destination = getDestination(session);
>
>            browser = session.createBrowser((Queue) destination);
>            Enumeration enumeration = browser.getEnumeration();
>
>            if (enumeration.hasMoreElements()) {
>                Object msg = enumeration.nextElement();
>
>                JMSPersistentMessage jmsMeg = (JMSPersistentMessage)
> ((ObjectMessage) msg).getObject();
>                messageContext =
> jmsPersistentMessageHelper.createMessageContext(jmsMeg);
>            }
>
>        } catch (JMSException e) {
>            log.error("JMS error while retrieving messages from the store: "
> + name, e);
>            error = true;
>            throw new SynapseException("JMS Message Store Exception " + e);
>        } finally {
>            cleanupJMSResources(con, session, browser, error,
> ConnectionType.READ_CONNECTION);
>        }
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Messages-are-repetedly-sends-by-the-queue-tp3664255p3664255.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message