OracleMessageListener

OracleMessageListener.java

package com.sachinhandiekar.oracle.aq;
 
import javax.jms.Message;
import javax.jms.MessageListener;
 
import org.springframework.transaction.annotation.Transactional;
 
import oracle.jms.AQjmsAdtMessage;
import oracle.xdb.XMLType;
 
public class OracleMessageListener implements MessageListener {
 
 @Transactional
 public void onMessage(Message message) {
 
  try {
 
   //Converting message into XmlType payload
   XMLType xmlMsg = (XMLType) ((AQjmsAdtMessage) message).getAdtPayload();
 
   System.out.println("XML Payload ==> " + xmlMsg.getStringVal());
 
  }
  catch (Exception e) {
   // Catch any exception here
   e.printStackTrace();
  }
 
 }
 
}