activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Klaus.Unger" <klaus.un...@iq-consultancy.net>
Subject Troubles receiving a Message with a Selector
Date Wed, 14 Sep 2011 16:07:55 GMT
Hello everybody,

I did search the forum for some similar questions/problems, but didn't find
matching entries.

I normally work with the Spring JmsTemplate, but did also try to reproduce
the problematic behaviour in a native ActiveMQ Java implementation.

// given factory is a ActiveMQConnectionFactory
        sendConnection = factory.createConnection();
        sendConnection.start();

        receiveConnection = factory.createConnection();
        receiveConnection.start();
 
        RecognitionSession recognitionSession = ... // my payload in the jms
message
        String selector = String.format("JMSCorrelationID='%s'",
recognitionSession.getClientSessionId());
 
        Session sendSession = sendConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = sendSession.createProducer(queue);
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
        Message message =
sendSession.createObjectMessage(recognitionSession);
       
message.setJMSCorrelationID(recognitionSession.getClientSessionId());
        message.setJMSTimestamp(System.currentTimeMillis());
        producer.send(message);
 
        Session receiveSession = receiveConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = receiveSession.createConsumer(queue,
selector);
        ObjectMessage receivedMessage = (ObjectMessage)
consumer.receive(25);
        RecognitionSession receivedRecognitionSession = null;

        if (receivedMessage != null) {
            receivedRecognitionSession = (RecognitionSession)
receivedMessage.getObject();
        }

        QueueBrowser browser = receiveSession.createBrowser(queue,
selector);
        // further checks if the recognitionSession is not in the delivered
Enumeration anymore

I did call this code in a kind of stress test 5000 times!

4964 times the message was received,
26 times the message receive(25) delivered null

any ideas, any hints welcome


--
View this message in context: http://activemq.2283324.n4.nabble.com/Troubles-receiving-a-Message-with-a-Selector-tp3813397p3813397.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message