trdq.java

oracle9i+j2ee开发aq oracle9i+j2ee开发aq oracle9i+j2ee开发aq

/* Copyright (c) Oracle Corporation 2001. All Rights Reserved. */

/*

   NAME
     trdq.java - a JMS example of doing transformation during a dequeue

   DESCRIPTION
     This examples does an dequeue into BZ_ADM.BZCARDORDERS_Q with a 
     transformation BZ_ADM.BZCARDVERIFY

*/

import oracle.AQ.*;
import oracle.jms.*;
import javax.jms.*;
import java.lang.*;

public class trdq {
  public static void main(String args[])
         throws java.sql.SQLException, ClassNotFoundException {
     TopicConnectionFactory tc_fact = null;
     TopicConnection        t_conn  = null;
     TopicSession           t_sess  = null;
     Topic                  t_queue = null;
     TopicReceiver          t_sub   = null;
     BzCardOrder            order   = null;

     AdtMessage             adt_msg = null;

     try {

//	 AQjmsOracleDebug.setTraceLevel(5);
//	 AQjmsOracleDebug.setDebug(true);

        tc_fact = AQjmsFactory.getTopicConnectionFactory("bgoyal-sun",
                                     "BGOYALDB", 1521, "thin");
        t_conn  = tc_fact.createTopicConnection("bz", "bz");
        t_sess  = t_conn.createTopicSession(true, Session.CLIENT_ACKNOWLEDGE);

	t_queue = ((AQjmsSession)t_sess).getTopic("BZ_ADM", "BZCARDORDERS_Q");
        
	t_sub = ((AQjmsSession)t_sess).createTopicReceiver(t_queue, "SHIPPING",
					      null, BzCardOrder.getFactory()); 

	((AQjmsTopicReceiver)t_sub).setTransformation("BZ_ADM.BZCARDVERIFY");
	adt_msg = (AdtMessage)t_sub.receive();

	t_sess.commit();
     } catch (Exception ex) {
	ex.printStackTrace();
     }
   }
}
/* end of file trdq.java */