PK 6S0META-INF/application.xml OracleJmsApp OracleJmsWar.war OracleJms OracleJmsEJB.jar PK 6S0yF META-INF/data-sources.xml PK 6S0META-INF/orion-application.xml PK 6S0Kt% % OracleJmsEJB.jarPK6S0META-INF/MANIFEST.MFMLK-. K-*ϳR03r.JM,IMuR/JLITrI-K/H-R33PK iB@PK 6S00META-INF/ejb-jar.xml Message Driven Bean parallelMDB parallelMDB parallelMDBBean Container Auto-acknowledge javax.jms.Queue PK 6S0a//META-INF/orion-ejb-jar.xml PK 6S0ʑparallelMDBBean.class-#   !"context Ljavax/ejb/MessageDrivenContext; CodeCoach()VCodeLineNumberTableLocalVariableTablethisLparallelMDBBean; ejbCreate onMessage(Ljavax/jms/Message;)VmsgLjavax/jms/Message; ejbRemovesetMessageDrivenContext#(Ljavax/ejb/MessageDrivenContext;)Vctx SourceFileparallelMDBBean.javaClass compiled with OJC parallelMDBBeanjava/lang/Objectjavax/ejb/MessageDrivenBeanjavax/jms/MessageListener!   9*      5       A       5     J*+    PK6S0 iB@META-INF/MANIFEST.MFPK 6S00META-INF/ejb-jar.xmlPK 6S0a//META-INF/orion-ejb-jar.xmlPK 6S0ʑparallelMDBBean.classPK PK 6S0qPPOracleJmsWar.warPK 6S0I4 WEB-INF/classes/OracleJmsWeb.cdi sC:\jhunter\programming\jdev\OracleJmsAQWA\OracleJmsAQWS\OracleJmsWeb\document_root\WEB-INF\classes\OracleJmsWeb.cdijava.sql.Statement javax.jms.QueueConnectionFactoryjavax.jms.TextMessagejavax.jms.QueueConnection%javax.servlet.http.HttpServletRequestjavax.servlet.ServletConfigjavax.servlet.http.HttpServletjavax.jms.Queuejava.io.PrintWriterjava.lang.System listDataSetjavax.jms.Sessionjavax.servlet.ServletExceptionjava.text.SimpleDateFormatjava.sql.SQLExceptionjava.sql.Connectionjava.io.IOException jobSubmitjava.io.PrintStreamjava.sql.ResultSetjava.lang.Stringjava.lang.Throwablejavax.sql.DataSourcejavax.jms.QueueSessionjavax.jms.QueueSenderjavax.naming.InitialContextvoidint&javax.servlet.http.HttpServletResponsejava.lang.IntegeroC:\jhunter\programming\jdev\OracleJmsAQWA\OracleJmsAQWS\OracleJmsWeb\document_root\WEB-INF\src\listDataSet.javamC:\jhunter\programming\jdev\OracleJmsAQWA\OracleJmsAQWS\OracleJmsWeb\document_root\WEB-INF\src\jobSubmit.java7Ylz7+|O lf+BzY|7+OJ lOf| JcBPK 6S0 WEB-INF/classes/connections.xml 1521 JDBC alex dw TARGDB_DW TARGDB oracle.jdbc.driver.OracleDriver thin 1521 JDBC alex system OIDDB_SYSTEM OIDDB oracle.jdbc.driver.OracleDriver thin 1521 JDBC alex system TARGDB_SYSTEM TARGDB oracle.jdbc.driver.OracleDriver thin 1521 JDBC alex system OMSDB_SYSTEM OMSDB oracle.jdbc.driver.OracleDriver thin 1521 JDBC bartman system O920NT_SYSTEM O920NT oracle.jdbc.driver.OracleDriver thin 1521 JDBC bartman cdrom O920NT_CDROM o920nt oracle.jdbc.driver.OracleDriver thin 1521 JDBC alex oe TARGDB_OE TARGDB oracle.jdbc.driver.OracleDriver thin BARTMAN_OC4J ormi://bartman/ OC4J admin com.evermind.server.rmi.RMIInitialContextFactory http-web-site PK 6S0 Y%%WEB-INF/classes/jobSubmit.class-  3 3   (             (  0 !" #$% &'( #)*+,-. /0 /12 3456789:;<=>?@ABCDEFG 3 HIJK 3LM &NOPQ RSTU RVWX RVY Z[\ &]^_`a /0 /1b cd cd cd efgh ijklm CONTENT_TYPELjava/lang/String; ConstantValue CodeCoach cLOG_PREFIX cQUEUE_NAME cQCF_NAME cQUEUE_USER cQUEUE_PASSWDcDS_NAME cCREATE_STMNT cDEF_STARTIcDEF_ENDd cDEF_SEGMENTS jndiContextLjavax/naming/InitialContext;queueLjavax/jms/Queue; queueSessionLjavax/jms/QueueSession; queueSenderLjavax/jms/QueueSender;queueConnectionFactory"Ljavax/jms/QueueConnectionFactory;queueConnectionLjavax/jms/QueueConnection;()VCodeLineNumberTableLocalVariableTablethis LjobSubmit; logMessage(Ljava/lang/String;)VpMsg createDataset (Ljavax/naming/InitialContext;)VctxdsLjavax/sql/DataSource;jdbcConnLjava/sql/Connection; jdbcStmntLjava/sql/Statement;sLjava/sql/SQLException;tLjava/lang/Throwable;intParam(Ljava/lang/String;I)IparamdefValueinit (Ljavax/servlet/ServletConfig;)VconfigLjavax/servlet/ServletConfig; queueUsername queuePassword ExceptionsndoGetR(Ljavax/servlet/http/HttpServletRequest;Ljavax/servlet/http/HttpServletResponse;)Vrequest'Ljavax/servlet/http/HttpServletRequest;response(Ljavax/servlet/http/HttpServletResponse;outLjava/io/PrintWriter;osubmitJobMessage(II)VstartendmessageLjavax/jms/TextMessage;doPostpSTARTpEND pSEGMENTSsegmentstmprangeqtycurrlooplast SourceFilejobSubmit.javaClass compiled with OJC p q jobSubmit:: rs tuv w xcreateDataset() ENTER java:comp/env/jdbc/DATASET yzjavax/sql/DataSource1createDataset() - jndiContext.lookup(cDS_NAME) OK {|&createDataset() - ds.getConnection(OK)} ~.createDataset() - jdbcConn.createStatement(OK)3CREATE TABLE dataset (insert_dt date, id number(4)) 'createDataset() - jdbcStmnt.execute(OK)java/sql/SQLExceptionjava/lang/ThrowablecreateDataset()::THROWABLE( ) @createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() []createDataset() EXIT  init() ENTER javax/naming/InitialContextinit() - InitialContext() OK java:comp/env/jms/JOB_QUEUEjavax/jms/Queue%init() - jndiContext.lookup(QUEUE) OKjava:comp/env/jms/JOB_QCF javax/jms/QueueConnectionFactory'init() - jndiContext.lookup(FACTORY) OKjava:comp/env/var/Q_USERNAMEjava/lang/String,init() - jndiContext.lookup(cQUEUE_USER) OK(java:comp/env/var/Q_PASSWORD.init() - jndiContext.lookup(cQUEUE_PASSWD) OK( init() - createQueueConnection(,) OK  init() - createQueueSession() OK init() - createSender() OK init() - start() OKinit()::THROWABLE( init() EXIT doGet() ENTERtext/html; charset=windows-1252  jobSubmit - GET
 33 6;8
Start:
End:Segments:

doGet()::THROWABLE( doGet() EXITsubmitJobMessage() ENTERsubmitJobMessage() START( rsubmitJobMessage() END( 8submitJobMessage() - queueSession.createTextMessage() OKJOB(.. )submitJobMessage() - message.setText() OKSTART 5submitJobMessage() - message.setIntProperty(START) OKEND3submitJobMessage() - message.setIntProperty(END) OK *submitJobMessage() - queueSender.send() OK -submitJobMessage() - queueSession.commit() OKsubmitJobMessage()::THROWABLE(submitJobMessage() EXITdoPost() ENTERjobSubmit - POST u LOOP()
#doPost()::CALLING submitJobMessage( doPost()::THROWABLE( doPost() EXIT jobSubmitjavax/servlet/http/HttpServletjavax/servlet/ServletExceptionjava/io/IOExceptionjava/lang/SystemLjava/io/PrintStream;valueOf&(Ljava/lang/Object;)Ljava/lang/String;concat&(Ljava/lang/String;)Ljava/lang/String;java/io/PrintStreamprintlnflushlookup&(Ljava/lang/String;)Ljava/lang/Object; getConnection()Ljava/sql/Connection;java/sql/ConnectioncreateStatement()Ljava/sql/Statement;java/sql/Statementexecute(Ljava/lang/String;)ZtoString()Ljava/lang/String;closejava/lang/IntegerparseInt(Ljava/lang/String;)IcreateQueueConnectionA(Ljava/lang/String;Ljava/lang/String;)Ljavax/jms/QueueConnection;javax/jms/QueueConnectioncreateQueueSession(ZI)Ljavax/jms/QueueSession;javax/jms/QueueSession createSender*(Ljavax/jms/Queue;)Ljavax/jms/QueueSender;&javax/servlet/http/HttpServletResponsesetContentType getWriter()Ljava/io/PrintWriter;java/io/PrintWriter(I)Ljava/lang/String;createTextMessage()Ljavax/jms/TextMessage;javax/jms/TextMessagesetTextsetIntProperty(Ljava/lang/String;I)Vjavax/jms/QueueSendersend(Ljavax/jms/Message;)Vcommit%javax/servlet/http/HttpServletRequest getParameter!D ,/25 !"$%&'()s#*******"$ %&'()" #a +  ./0-- MN:**M*,N*-:*W* :*5:*   j:: $:*!  " -#$:*!  " *$;KNV\f567: <= ?'@-B5C;FEGNHPI\K^MORSTXYZ]`\ P^ 3567HKSY3~+%>N6fjgh j* ccgc0X*&*+'*(Y)****+**,-*.**/0*1*23M*4 ,  *53N*6 -  **,-7*8 , 9 - : **;*<***=*>*?*@3:M*A ,  ::*B EEjqr tuw$y4z:|J}P]x  !EOW4XX]! mm*C,DE,FN-GH-IH-JH-KH-LH-MH-NH-OH-PH-QH-RH-OH-SH-TH-RH-OH-UH-VH-RH-OH-WH-XH-RH-YH-ZH-[H-\H-]3:N*^ -  ::*_$!'-39?EKQW]ciou{4 *`*a b  *c b  *dN*e-f b g b  h*i-jk*l-mn*o*-p*q*r*s3:N*t -  ::*uR!<FL~4F{ S*v,Dw,xN-GH-IH-yH-KH-LH+z{:+|}:+~:*6*d6*d6 6d66 6 6d`6  d6    6   l6 6 6   6  6   `d6-  b g b  H*  b 9 b  * `6 j-[H-\H-]3:N* -  ::*io+!'-3 = G Q Zdnw !#$&')+,E-M/S#Y2_3e4o6p789<T=,G"QZdn  p$     !#$6PK 6S0Em''!WEB-INF/classes/listDataSet.class- U T T   T #       U # T    9   9    T CONTENT_TYPELjava/lang/String; ConstantValue CodeCoach cLOG_PREFIXcDS_NAME cCREATE_STMNT cQUERY_STMNT jndiContextLjavax/naming/InitialContext;dsLjavax/sql/DataSource;()VCodeLineNumberTableLocalVariableTablethis LlistDataSet; logMessage(Ljava/lang/String;)VpMsg createDataset (Ljavax/naming/InitialContext;)VctxjdbcConnLjava/sql/Connection; jdbcStmntLjava/sql/Statement;sLjava/sql/SQLException;tLjava/lang/Throwable;init (Ljavax/servlet/ServletConfig;)VconfigLjavax/servlet/ServletConfig; ExceptionsdoGetR(Ljavax/servlet/http/HttpServletRequest;Ljavax/servlet/http/HttpServletResponse;)Vrequest'Ljavax/servlet/http/HttpServletRequest;response(Ljavax/servlet/http/HttpServletResponse;outLjava/io/PrintWriter;resultsLjava/sql/ResultSet;sdfLjava/text/SimpleDateFormat;rowsI insert_dtLjava/sql/Timestamp;iddoPost SourceFilelistDataSet.javaClass compiled with OJC bc ^_ `a  listDataSet::  j ccreateDataset() ENTER ijjava:comp/env/jdbc/DATASET javax/sql/DataSource1createDataset() - jndiContext.lookup(cDS_NAME) OK &createDataset() - ds.getConnection(OK) .createDataset() - jdbcConn.createStatement(OK)3CREATE TABLE dataset (insert_dt date, id number(4)) 'createDataset() - jdbcStmnt.execute(OK)java/sql/SQLExceptionjava/lang/ThrowablecreateDataset()::THROWABLE( ) c@createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() []createDataset() EXIT init() ENTER wxjavax/naming/InitialContextinit() - InitialContext() OK lm(init() - jndiContext.lookup(cDS_NAME) OKinit()::THROWABLE( init() EXIT doGet() ENTERtext/html; charset=windows-1252 j  listDataSet - GETdoGet() - ds.getConnection(OK)&doGet() - jdbcConn.createStatement(OK)9SELECT insert_dt, id FROM dataset ORDER BY insert_dt DESC   $doGet() - jdbcStmnt.executeQuery(OK)java/text/SimpleDateFormatEEE, d MMM yyyy HH:mm:ss bj       
DATESTAMPID

doGet() - ds.executeQuery(NULL)#

Dataset is currently empty

doGet()::THROWABLE(6doGet()::THROWABLE::finally::CALLING results.close() [8doGet()::THROWABLE::finally::CALLING jdbcStmnt.close() [ doGet() EXITdoPost() ENTER }~ doPost() EXIT listDataSetjavax/servlet/http/HttpServletjavax/servlet/ServletExceptionjava/io/IOExceptionjava/lang/SystemLjava/io/PrintStream;java/lang/StringvalueOf&(Ljava/lang/Object;)Ljava/lang/String;concat&(Ljava/lang/String;)Ljava/lang/String;java/io/PrintStreamprintlnflushlookup&(Ljava/lang/String;)Ljava/lang/Object; getConnection()Ljava/sql/Connection;java/sql/ConnectioncreateStatement()Ljava/sql/Statement;java/sql/Statementexecute(Ljava/lang/String;)ZtoString()Ljava/lang/String;close&javax/servlet/http/HttpServletResponsesetContentType getWriter()Ljava/io/PrintWriter;java/io/PrintWriter executeQuery((Ljava/lang/String;)Ljava/sql/ResultSet;java/sql/ResultSetnext()Z getTimestamp(I)Ljava/sql/Timestamp;getInt(I)Iformat$(Ljava/util/Date;)Ljava/lang/String;(I)Ljava/lang/String;!TUVWX+YZWXY[WX Y\WXY]WX6Y^_Y`aYbcdO***e f ghYYijda+ e !"fghkWYYlmd MN:* * M* ,N* -:* W* :* 5:* j::$:* -$:* * ;KNV\ef'()- /0 2'3-556;9E:N;P<\?^ACFGHLMNQTf\ ghn_`aopqrPst^uvuvuvY %'();?GMY%wxdv*! *+"*#Y$*% **&** *' 18M*(, N-:*) :@eee2 \] _`b$d4e@gAheimjulf vghvyzAuvYXg{|YX}~dN:::** ,+,,-N-./-0/-1/-2/-3/*:*4 :*5 67:*8 9Y:;:6<!-=/->/-?/-@/-A/B: C6 ->/-D EF/-D GF/-A/r -H/*I -J/5:*K :  : L$: *M  $: *N  $: *N  *O -P  )/ VV`gje5stuv z|} &,28>IOX^ioz}#/1V`jlfghopqr z}S I 1uvluv uv uv Y ppstuv{|Yp~dk*Q *+,R*S e f ghY{|YYPK 6S0{WEB-INF/orion-web.xml aq_admin aq_admin PK 6S0=-**WEB-INF/src/jobSubmit.java// ----------------------------------------------------------------------------- // jobSubmit.java // ----------------------------------------------------------------------------- import java.io.*; import java.sql.*; import java.util.*; import javax.ejb.*; import javax.jms.*; import javax.naming.*; import javax.rmi.*; import javax.servlet.*; import javax.servlet.http.*; import javax.sql.*; public class jobSubmit extends HttpServlet { private static final String CONTENT_TYPE = "text/html; charset=windows-1252"; private static final String cLOG_PREFIX = "jobSubmit::"; private static final String cQUEUE_NAME = "java:comp/env/jms/JOB_QUEUE"; private static final String cQCF_NAME = "java:comp/env/jms/JOB_QCF"; private static final String cQUEUE_USER = "java:comp/env/var/Q_USERNAME"; private static final String cQUEUE_PASSWD = "java:comp/env/var/Q_PASSWORD"; private static final String cDS_NAME = "java:comp/env/jdbc/DATASET"; private static final String cCREATE_STMNT = "CREATE TABLE dataset (insert_dt date, id number(4))"; private static final int cDEF_START = 1; private static final int cDEF_END = 100; private static final int cDEF_SEGMENTS = 100; private InitialContext jndiContext = null; private Queue queue = null; private QueueSession queueSession = null; private QueueSender queueSender = null; private QueueConnectionFactory queueConnectionFactory = null; private QueueConnection queueConnection = null; public void logMessage(String pMsg) { System.out.println(cLOG_PREFIX+pMsg); System.out.flush(); } public void createDataset(InitialContext ctx) { javax.sql.DataSource ds = null; java.sql.Connection jdbcConn = null; java.sql.Statement jdbcStmnt = null; try { logMessage("createDataset() ENTER"); ds=(DataSource)jndiContext.lookup(cDS_NAME); logMessage("createDataset() - jndiContext.lookup(cDS_NAME) OK"); jdbcConn = ds.getConnection(); logMessage("createDataset() - ds.getConnection(OK)"); jdbcStmnt = jdbcConn.createStatement(); logMessage("createDataset() - jdbcConn.createStatement(OK)"); try { jdbcStmnt.execute(cCREATE_STMNT); logMessage("createDataset() - jdbcStmnt.execute(OK)"); } catch (SQLException s) { logMessage("createDataset() - jdbcStmnt.execute(OK)"); } } catch (Throwable t) { logMessage("createDataset()::THROWABLE("+t.toString()+")"); } finally { try { jdbcStmnt.close(); } catch (Throwable t) { logMessage("createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } try { jdbcConn.close(); } catch (Throwable t) { logMessage("createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } logMessage("createDataset() EXIT"); } } public int intParam(String param, int defValue) { try { return Integer.parseInt(param); } catch (Throwable t) { return defValue; } } public void init(ServletConfig config) throws ServletException { try { logMessage("init() ENTER"); super.init(config); jndiContext=new InitialContext(); logMessage("init() - InitialContext() OK"); createDataset(jndiContext); queue = (Queue)jndiContext.lookup(cQUEUE_NAME); logMessage("init() - jndiContext.lookup(QUEUE) OK"); queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup(cQCF_NAME); logMessage("init() - jndiContext.lookup(FACTORY) OK"); String queueUsername=(String)jndiContext.lookup(cQUEUE_USER); logMessage("init() - jndiContext.lookup(cQUEUE_USER) OK("+queueUsername+")"); String queuePassword=(String)jndiContext.lookup(cQUEUE_PASSWD); logMessage("init() - jndiContext.lookup(cQUEUE_PASSWD) OK("+queuePassword+")"); queueConnection=queueConnectionFactory.createQueueConnection(queueUsername,queuePassword); logMessage("init() - createQueueConnection("+queueUsername+","+queuePassword+") OK"); queueSession=queueConnection.createQueueSession(true,Session.AUTO_ACKNOWLEDGE); logMessage("init() - createQueueSession() OK"); queueSender=queueSession.createSender(queue); logMessage("init() - createSender() OK"); queueConnection.start(); logMessage("init() - start() OK"); } catch (Throwable t) { logMessage("init()::THROWABLE("+t.toString()+")"); } finally { logMessage("init() EXIT"); } } public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { try { logMessage("doGet() ENTER"); response.setContentType(CONTENT_TYPE); PrintWriter out = response.getWriter(); out.println(""); out.println(""); out.println("jobSubmit - GET"); out.println(""); out.println(""); out.println("
"); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); out.println("
Start:
End:
Segments:
"); out.println("
"); out.println(""); out.println(""); out.close(); } catch (Throwable t) { logMessage("doGet()::THROWABLE("+t.toString()+")"); } finally { logMessage("doGet() EXIT"); } } public void submitJobMessage(int start, int end) throws Throwable { try { logMessage("submitJobMessage() ENTER"); logMessage("submitJobMessage() START("+start+")"); logMessage("submitJobMessage() END("+end+")"); TextMessage message = queueSession.createTextMessage(); logMessage("submitJobMessage() - queueSession.createTextMessage() OK"); message.setText("JOB("+start+".."+end+")"); logMessage("submitJobMessage() - message.setText() OK"); message.setIntProperty("START",start); logMessage("submitJobMessage() - message.setIntProperty(START) OK"); message.setIntProperty("END",end); logMessage("submitJobMessage() - message.setIntProperty(END) OK"); queueSender.send(message); logMessage("submitJobMessage() - queueSender.send() OK"); queueSession.commit(); logMessage("submitJobMessage() - queueSession.commit() OK"); } catch (Throwable t) { logMessage("submitJobMessage()::THROWABLE("+t.toString()+")"); } finally { logMessage("submitJobMessage() EXIT"); } } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { try { logMessage("doPost() ENTER"); response.setContentType(CONTENT_TYPE); PrintWriter out = response.getWriter(); out.println(""); out.println(""); out.println("jobSubmit - POST"); out.println(""); out.println(""); //*** GET PARAMETERS *** String pSTART = request.getParameter("pSTART"); String pEND = request.getParameter("pEND"); String pSEGMENTS = request.getParameter("pSEGMENTS"); int start=intParam(pSTART,cDEF_START); int end=intParam(pEND,cDEF_END); int segments=intParam(pSEGMENTS,cDEF_SEGMENTS); if (start<1) start=cDEF_START; if (end<1) end=cDEF_END; if (start>end) { int tmp=start; start=end; end=tmp; } int range=end-start+1; if (segments<1) segments=cDEF_SEGMENTS; if (range"); logMessage("doPost()::CALLING submitJobMessage("+curr+","+last+")"); submitJobMessage(curr,last); curr=last+1; } out.println(""); out.println(""); out.close(); } catch (Throwable t) { logMessage("doPost()::THROWABLE("+t.toString()+")"); } finally { logMessage("doPost() EXIT"); } } } PK 6S0h2WEB-INF/src/listDataSet.java// ----------------------------------------------------------------------------- // listDataSet.java // ----------------------------------------------------------------------------- import java.io.*; import java.lang.*; import java.sql.*; import java.util.*; import java.text.*; import javax.naming.*; import javax.rmi.*; import javax.servlet.*; import javax.servlet.http.*; import javax.sql.*; public class listDataSet extends HttpServlet { private static final String CONTENT_TYPE = "text/html; charset=windows-1252"; private static final String cLOG_PREFIX = "listDataSet::"; private static final String cDS_NAME = "java:comp/env/jdbc/DATASET"; private static final String cCREATE_STMNT = "CREATE TABLE dataset (insert_dt date, id number(4))"; private static final String cQUERY_STMNT = "SELECT insert_dt, id FROM dataset ORDER BY insert_dt DESC"; private InitialContext jndiContext = null; private DataSource ds = null; public void logMessage(String pMsg) { System.out.println(cLOG_PREFIX+pMsg); System.out.flush(); } public void createDataset(InitialContext ctx) { javax.sql.DataSource ds = null; java.sql.Connection jdbcConn = null; java.sql.Statement jdbcStmnt = null; try { logMessage("createDataset() ENTER"); ds=(DataSource)jndiContext.lookup(cDS_NAME); logMessage("createDataset() - jndiContext.lookup(cDS_NAME) OK"); jdbcConn = ds.getConnection(); logMessage("createDataset() - ds.getConnection(OK)"); jdbcStmnt = jdbcConn.createStatement(); logMessage("createDataset() - jdbcConn.createStatement(OK)"); try { jdbcStmnt.execute(cCREATE_STMNT); logMessage("createDataset() - jdbcStmnt.execute(OK)"); } catch (SQLException s) { logMessage("createDataset() - jdbcStmnt.execute(OK)"); } } catch (Throwable t) { logMessage("createDataset()::THROWABLE("+t.toString()+")"); } finally { try { jdbcStmnt.close(); } catch (Throwable t) { logMessage("createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } try { jdbcConn.close(); } catch (Throwable t) { logMessage("createDataset()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } logMessage("createDataset() EXIT"); } } public void init(ServletConfig config) throws ServletException { try { logMessage("init() ENTER"); super.init(config); jndiContext=new InitialContext(); logMessage("init() - InitialContext() OK"); createDataset(jndiContext); ds=(DataSource)jndiContext.lookup(cDS_NAME); logMessage("init() - jndiContext.lookup(cDS_NAME) OK"); } catch (Throwable t) { logMessage("init()::THROWABLE("+t.toString()+")"); } finally { logMessage("init() EXIT"); } } public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PrintWriter out = null; Connection jdbcConn = null; Statement jdbcStmnt = null; ResultSet results = null; try { logMessage("doGet() ENTER"); response.setContentType(CONTENT_TYPE); out = response.getWriter(); out.println(""); out.println(""); out.println("listDataSet - GET"); out.println(""); out.println(""); jdbcConn = ds.getConnection(); logMessage("doGet() - ds.getConnection(OK)"); jdbcStmnt = jdbcConn.createStatement(); logMessage("doGet() - jdbcConn.createStatement(OK)"); results = jdbcStmnt.executeQuery(cQUERY_STMNT); logMessage("doGet() - jdbcStmnt.executeQuery(OK)"); SimpleDateFormat sdf = new SimpleDateFormat("EEE, d MMM yyyy HH:mm:ss"); int rows = 0; while (results.next()) { rows++; if (rows==1) { out.println(""); out.println(""); out.println(""); out.println(""); out.println(""); } java.sql.Timestamp insert_dt = (java.sql.Timestamp)results.getTimestamp(1); int id = results.getInt(2); out.println(""); out.println(""); out.println(""); out.println(""); } if (rows>1) { out.println("
DATESTAMPID
"+sdf.format(insert_dt)+""+id+"
"); } else { logMessage("doGet() - ds.executeQuery(NULL)"); out.println("

Dataset is currently empty

"); } } catch (Throwable t) { logMessage("doGet()::THROWABLE("+t.toString()+")"); } finally { try { results.close(); } catch (Throwable t) { logMessage("doGet()::THROWABLE::finally::CALLING results.close() ["+t.toString()+"]"); } try { jdbcStmnt.close(); } catch (Throwable t) { logMessage("doGet()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } try { jdbcConn.close(); } catch (Throwable t) { logMessage("doGet()::THROWABLE::finally::CALLING jdbcStmnt.close() ["+t.toString()+"]"); } logMessage("doGet() EXIT"); out.close(); } } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { logMessage("doPost() ENTER"); doGet(request,response); logMessage("doPost() EXIT"); } } PK 6S0WEB-INF/web.xml J2EE Web Deployment Descriptor jobSubmit jobSubmit jobSubmit /jobSubmit listDataSet listDataSet listDataSet /listDataSet 30 html text/html txt text/plain index.jsp index.html Job Queue Username var/Q_USERNAME java.lang.String Job Queue Password var/Q_PASSWORD java.lang.String Data source for row creation jdbc/DATASET javax.sql.DataSource Container Job Submission Queue Connection Factory jms/JOB_QCF javax.jms.QueueConnectionFactory Container Job Submission Queue jms/JOB_QUEUE javax.jms.Queue Container PK 6S0I4 WEB-INF/classes/OracleJmsWeb.cdiPK 6S0 9WEB-INF/classes/connections.xmlPK 6S0 Y%%%WEB-INF/classes/jobSubmit.classPK 6S0Em''!9WEB-INF/classes/listDataSet.classPK 6S0{iQWEB-INF/orion-web.xmlPK 6S0=-**TWEB-INF/src/jobSubmit.javaPK 6S0h2WEB-INF/src/listDataSet.javaPK 6S0ۚWEB-INF/web.xmlPKMPK 6S0META-INF/application.xmlPK 6S0yF META-INF/data-sources.xmlPK 6S0 META-INF/orion-application.xmlPK 6S0Kt% % zOracleJmsEJB.jarPK 6S0qPPOracleJmsWar.warPKYK