A custom Oracle AQ MessageListener Container (XML Type payload) for Spring JMS

OracleXMLMessageListenerContainer.java

package com.sachinhandiekar.oracle.aq;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;

import oracle.jms.AQjmsSession;
import oracle.xdb.XMLType;

import org.springframework.jms.listener.DefaultMessageListenerContainer;

public class OracleXMLMessageListenerContainer extends DefaultMessageListenerContainer {

	protected MessageConsumer createConsumer(Session session, Destination destination) throws JMSException {
		return ((AQjmsSession) session).createConsumer(destination, null, XMLType.getORADataFactory(), null, false);
	}

}