JMSCorrelationID together with Oracle AQ [SWS-742]

[gregturn]

Marakov Andrey opened SWS-742 and commented

In org.springframework.ws.transport.jms.JmsSenderConnection.onReceiveBeforeRead() the following code set the value of messageSelector:

if (responseDestination instanceof TemporaryQueue || responseDestination instanceof TemporaryTopic) {
       messageConsumer = session.createConsumer(responseDestination);
} else {
       String messageId = requestMessage.getJMSMessageID().replaceAll("'", "''");
       String messageSelector = "JMSCorrelationID = '" + messageId + "'";
       messageConsumer = session.createConsumer(responseDestination, messageSelector);
}

If I'm using Oracle AQ, expression (responseDestination instanceof TemporaryQueue) always returns true (See Oracle Streams Advanced Queuing Java API Reference http://docs.oracle.com/cd/B19306_01/server.102/b14291/oracle/jms/AQjmsDestination.html). Regarding this it is impossible to use JMSCorrelationID together with Oracle AQ.

---

Affects: 2.0.3

Referenced from: commits 09bcd7f

[gregturn]

Arjen Poutsma commented

Fixed.

[gregturn]

Arjen Poutsma commented

Closing old issues