sachin-handiekar

package com.sachinhandiekar.examples.cxf.logging;

import java.io.ByteArrayInputStream;
import java.io.StringWriter;
import java.util.Arrays;
import java.util.List;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.transform.OutputKeys;

sachin-handiekar

import org.opends.sdk.Connection;
import org.opends.sdk.ConnectionFactory;
import org.opends.sdk.Connections;
import org.opends.sdk.LDAPConnectionFactory;
import org.opends.sdk.LDAPOptions;
import org.opends.sdk.requests.BindRequest;
import org.opends.sdk.requests.PasswordModifyExtendedRequest;
import org.opends.sdk.requests.Requests;
import org.opends.sdk.responses.PasswordModifyExtendedResult;
 

sachin-handiekar

DECLARE
  
  queue_options DBMS_AQ.ENQUEUE_OPTIONS_T; 
  message_properties DBMS_AQ.MESSAGE_PROPERTIES_T; 
  message_id RAW(16); 
  message SYS.XMLType; 
  
BEGIN
  
  message := sys.XMLType.createXML('<sample>hello world</sample>');

sachin-handiekar

SET serveroutput ON format word_wrapped;
 
DECLARE
  queue_options DBMS_AQ.DEQUEUE_OPTIONS_T;
  message_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
  message_id RAW(16);
  MESSAGE SYS.XMLType;
  no_messages EXCEPTION;
  PRAGMA EXCEPTION_INIT (no_messages, -25228); 
BEGIN

sachin-handiekar

BEGIN
   DBMS_AQADM.CREATE_QUEUE_TABLE( 
                           Queue_table => 'QT_SAMPLE', 
                           Queue_payload_type => 'SYS.XMLTYPE', 
                           Sort_list => 'ENQ_TIME', 
                           COMMENT => 'A sample queue table');
END;

sachin-handiekar

BEGIN 
   DBMS_AQADM.CREATE_QUEUE( 
                          Queue_name => 'Q_SAMPLE', 
                          Queue_table => 'QT_SAMPLE', 
                          Queue_type => 0, 
                          Max_retries => 5, 
                          Retry_delay => 10);
END;

sachin-handiekar

package com.sachinhandiekar.oracle.aq;
 
import javax.jms.ConnectionFactory;
import javax.sql.DataSource;
 
public class OracleAQQueueConnectionFactory {
 
 private DataSource dataSource;
 
 public ConnectionFactory createConnectionFactory() throws Exception {

sachin-handiekar

package com.sachinhandiekar.oracle.aq;
 
import org.springframework.beans.factory.FactoryBean;
import oracle.jms.AQjmsSession;
 
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;
 

sachin-handiekar

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;
 

sachin-handiekar

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;