[jboss-svn-commits] JBL Code SVN: r16022 - in labs/jbossesb/trunk/product/samples/quickstarts: aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test and 8 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Oct 23 12:31:38 EDT 2007
Author: kurt.stam at jboss.com
Date: 2007-10-23 12:31:38 -0400 (Tue, 23 Oct 2007)
New Revision: 16022
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test/ReceiveJMSMessage.java
labs/jbossesb/trunk/product/samples/quickstarts/dynamic_router/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java
labs/jbossesb/trunk/product/samples/quickstarts/recipient_list/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/ReceiveJMSMessage.java
labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java
Log:
JBESB-736, JBESB-989 addressing issues mentioned in these JIRA. It's crazy we have more then version of this class.
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -65,7 +65,7 @@
<target name="receiveBlue" depends="compile"
description="receiveBlue">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Aggregator_Blue_Alert"/>
<classpath refid="exec-classpath"/>
</java>
@@ -74,7 +74,7 @@
<target name="receiveRed" depends="compile"
description="receiveRed">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Aggregator_Red_Alert"/>
<classpath refid="exec-classpath"/>
</java>
@@ -83,7 +83,7 @@
<target name="receiveGreen" depends="compile"
description="receiveGreen">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.aggregator.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Aggregator_Green_Alert"/>
<classpath refid="exec-classpath"/>
</java>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test/ReceiveJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test/ReceiveJMSMessage.java 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test/ReceiveJMSMessage.java 2007-10-23 16:31:38 UTC (rev 16022)
@@ -18,106 +18,124 @@
* (C) 2005-2006,
* @author JBoss Inc.
*/
-package org.jboss.soa.esb.samples.quickstart.aggregator.test;
-
-import javax.jms.Queue;
-import javax.jms.QueueConnection;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.QueueReceiver;
-import javax.jms.QueueSession;
-import javax.jms.TextMessage;
-import javax.naming.InitialContext;
-
-public class ReceiveJMSMessage {
- QueueConnection conn = null;
- QueueSession receiverSession = null;
- Queue receiverQueue = null;
- QueueReceiver queueReceiver = null;
- InitialContext iniCtx = null;
- QueueConnectionFactory qcf = null;
- String receiveQueueName = "queue/D"; // Default to queue/D
- private boolean initialised ;
-
- public ReceiveJMSMessage() {
-
- }
- public void receiveOne() {
- if (!initialised) {
- initialise() ;
- }
-
- if (receiverQueue != null) {
- try {
- TextMessage msg = (TextMessage) queueReceiver.receive();
- if (msg != null) {
- System.out.println("*********************************************************");
- System.out.println(msg.getText());
- System.out.println("*********************************************************");
- }
- } catch (final Exception ex) {
- cleanup() ;
- System.out.println(ex.getMessage()) ;
- }
- }
-
- if (!initialised) {
- System.out.println("Pausing before reinitialising") ;
- try {
- Thread.sleep(5000) ;
- } catch (final InterruptedException ie) {
- // do nothing
- }
- }
- }
-
- private void initialise()
- {
- try {
- if (iniCtx == null) iniCtx = new InitialContext();
- if (qcf == null) qcf = (QueueConnectionFactory) iniCtx.lookup("ConnectionFactory");
- if (conn == null) {
- conn = qcf.createQueueConnection();
- conn.start();
- }
- receiverQueue = (Queue) iniCtx.lookup(receiveQueueName);
- receiverSession = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
- queueReceiver = receiverSession.createReceiver(receiverQueue);
- initialised = true ;
- System.out.println("Initialised") ;
- } catch (final Exception ex) {
- cleanup() ;
- }
- }
-
- public void cleanup() {
- queueReceiver = null ;
- receiverSession = null ;
- receiverQueue = null ;
- try {
- conn.stop() ;
- } catch (final Exception ex) {
- // Do nothing ;
- }
- conn = null ;
- qcf = null ;
- iniCtx = null ;
- initialised = false ;
- }
-
- public static void main(String[] args) {
- final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
-
- if ((args.length > 0) && (args[0] != null)) {
- receiver.receiveQueueName = args[0];
- System.out.println("Receiving on: " + receiver.receiveQueueName );
- }
- Runtime.getRuntime().addShutdownHook(new Thread() {
- public void run() {
- receiver.cleanup() ;
- }
- }) ;
- while (true) { // loop until I'm killed
- receiver.receiveOne();
- }
- }
-}
+package org.jboss.soa.esb.samples.quickstart.aggregator.test;
+
+import javax.jms.Queue;
+import javax.jms.QueueConnection;
+import javax.jms.QueueConnectionFactory;
+import javax.jms.QueueReceiver;
+import javax.jms.QueueSession;
+import javax.jms.TextMessage;
+import javax.naming.InitialContext;
+
+
+public class ReceiveJMSMessage {
+ QueueConnection conn = null;
+ QueueSession receiverSession = null;
+ Queue receiverQueue = null;
+ QueueReceiver queueReceiver = null;
+ InitialContext iniCtx = null;
+ QueueConnectionFactory qcf = null;
+ String receiveQueueName = "queue/D"; // Default to queue/D
+ private boolean initialised ;
+
+ public ReceiveJMSMessage() {
+
+ }
+ public void receiveOne() {
+ if (!initialised) {
+ initialise() ;
+ }
+
+ if (receiverQueue != null) {
+ try {
+ TextMessage msg = (TextMessage) queueReceiver.receive();
+ if (msg != null) {
+ System.out.println("*********************************************************");
+ System.out.println(msg.getText());
+ System.out.println("*********************************************************");
+ }
+ } catch (final Exception ex) {
+ cleanup() ;
+ System.out.println(ex.getMessage()) ;
+ }
+ }
+
+ if (!initialised) {
+ System.out.println("Pausing before reinitialising") ;
+ try {
+ Thread.sleep(5000) ;
+ } catch (final InterruptedException ie) {
+ // do nothing
+ }
+ }
+ }
+
+ private void initialise()
+ {
+ try {
+ if (iniCtx == null) iniCtx = new InitialContext();
+ if (qcf == null) qcf = (QueueConnectionFactory) iniCtx.lookup("ConnectionFactory");
+ if (conn == null) {
+ conn = qcf.createQueueConnection();
+ conn.start();
+ }
+ receiverQueue = (Queue) iniCtx.lookup(receiveQueueName);
+ receiverSession = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+ queueReceiver = receiverSession.createReceiver(receiverQueue);
+ initialised = true ;
+ System.out.println("Initialised") ;
+ } catch (final Exception ex) {
+ cleanup() ;
+ }
+ }
+
+ public void cleanup() {
+ System.out.println("Closing connections");
+ queueReceiver = null ;
+ receiverSession = null ;
+ receiverQueue = null ;
+ if (receiverSession!=null) {
+ try {
+ receiverSession.close();
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
+ if (conn!=null) {
+ try {
+ conn.close() ;
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
+ conn = null ;
+ qcf = null ;
+ iniCtx = null ;
+ initialised = false ;
+ System.out.println("Closing completed");
+ }
+
+ public static void main(String[] args) {
+ final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+
+ if ((args.length > 0) && (args[0] != null)) {
+ receiver.receiveQueueName = args[0];
+ System.out.println("Receiving on: " + receiver.receiveQueueName );
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ receiver.cleanup() ;
+ }
+ }) ;
+ while (true) { // loop until I'm killed
+ receiver.receiveOne();
+ try {
+ Thread.sleep(500);
+ } catch (InterruptedException e) {break;}
+ }
+
+ } else {
+ System.out.println("Usage <queue-name>");
+ }
+ }
+}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/dynamic_router/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/dynamic_router/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/dynamic_router/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -20,7 +20,7 @@
<target name="receive-destination3" depends="compile">
<echo>Runs Test destination message receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.dynamicRouter.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.dynamicRouter.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/qsdynamicrouter_3_Request"/>
<arg value=":OK"/>
<classpath refid="exec-classpath"/>
@@ -29,7 +29,7 @@
<target name="receive-destination1" depends="compile">
<echo>Runs Test destination 1 message receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.dynamicRouter.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.dynamicRouter.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/qsdynamicrouter_1_Request"/>
<arg value=":OK"/>
<classpath refid="exec-classpath"/>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -23,7 +23,7 @@
<target name="receiveBlue" depends="compile"
description="willl receive a message from the quickstart_FunCBR_Green_Blue queue">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Fun_CBR_Blue_Alert"/>
<classpath refid="exec-classpath" />
</java>
@@ -32,7 +32,7 @@
<target name="receiveRed" depends="compile"
description="willl receive a message from the quickstart_FunCBR_Green_Red queue">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Fun_CBR_Red_Alert"/>
<classpath refid="exec-classpath" />
</java>
@@ -41,7 +41,7 @@
<target name="receiveGreen" depends="compile"
description="willl receive a message from the quickstart_FunCBR_Green_Alert queue">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.funcbr.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/quickstart_Fun_CBR_Green_Alert"/>
<classpath refid="exec-classpath" />
</java>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java 2007-10-23 16:31:38 UTC (rev 16022)
@@ -90,18 +90,29 @@
}
public void cleanup() {
+ System.out.println("Closing connections");
queueReceiver = null ;
receiverSession = null ;
receiverQueue = null ;
- try {
- conn.stop() ;
- } catch (final Exception ex) {
- // Do nothing ;
+ if (receiverSession!=null) {
+ try {
+ receiverSession.close();
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
}
+ if (conn!=null) {
+ try {
+ conn.close() ;
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
conn = null ;
qcf = null ;
iniCtx = null ;
initialised = false ;
+ System.out.println("Closing completed");
}
public static void main(String[] args) {
@@ -110,14 +121,20 @@
if ((args.length > 0) && (args[0] != null)) {
receiver.receiveQueueName = args[0];
System.out.println("Receiving on: " + receiver.receiveQueueName );
- }
- Runtime.getRuntime().addShutdownHook(new Thread() {
- public void run() {
- receiver.cleanup() ;
- }
- }) ;
- while (true) { // loop until I'm killed
- receiver.receiveOne();
- }
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ receiver.cleanup() ;
+ }
+ }) ;
+ while (true) { // loop until I'm killed
+ receiver.receiveOne();
+ try {
+ Thread.sleep(500);
+ } catch (InterruptedException e) {break;}
+ }
+
+ } else {
+ System.out.println("Usage <queue-name>");
+ }
}
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/recipient_list/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/recipient_list/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/recipient_list/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -36,7 +36,7 @@
<target name="receive-destination" depends="compile">
<echo>Runs Test Recipient List destination regular message receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/qsrecipientlist_regular_Request"/>
<classpath refid="exec-classpath"/>
</java>
@@ -44,7 +44,7 @@
<target name="receive-destination1" depends="compile">
<echo>Runs Test Recipient List destination 1 message receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/qsrecipientlist_1_Request"/>
<classpath refid="exec-classpath"/>
</java>
@@ -52,7 +52,7 @@
<target name="receive-destination2" depends="compile">
<echo>Runs Test Recipient List destination 2 message receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.recipientList.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/qsrecipientlist_2_Request"/>
<classpath refid="exec-classpath"/>
</java>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -19,7 +19,7 @@
<target name="receiveExpress" description="runs Test JMS Receiver express" depends="compile">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.simplecbr.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.simplecbr.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/CBRExpressFreeShippingAlert"/>
<classpath refid="exec-classpath"/>
</java>
@@ -27,7 +27,7 @@
<target name="receiveNormal" description="runs Test JMS Receive normal" depends="compile">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.simplecbr.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.simplecbr.test.ReceiveJMSMessage" failonerror="true">
<arg value="queue/CBRNormalShippingAlert"/>
<classpath refid="exec-classpath"/>
</java>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/ReceiveJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/ReceiveJMSMessage.java 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/ReceiveJMSMessage.java 2007-10-23 16:31:38 UTC (rev 16022)
@@ -29,95 +29,112 @@
import javax.naming.InitialContext;
public class ReceiveJMSMessage {
- QueueConnection conn = null;
- QueueSession receiverSession = null;
- Queue receiverQueue = null;
- QueueReceiver queueReceiver = null;
- InitialContext iniCtx = null;
- QueueConnectionFactory qcf = null;
- String receiveQueueName = "queue/D"; // Default to queue/D
- private boolean initialised ;
-
- public ReceiveJMSMessage() {
-
- }
- public void receiveOne() {
- if (!initialised) {
- initialise() ;
+ QueueConnection conn = null;
+ QueueSession receiverSession = null;
+ Queue receiverQueue = null;
+ QueueReceiver queueReceiver = null;
+ InitialContext iniCtx = null;
+ QueueConnectionFactory qcf = null;
+ String receiveQueueName = "queue/D"; // Default to queue/D
+ private boolean initialised ;
+
+ public ReceiveJMSMessage() {
+
+ }
+ public void receiveOne() {
+ if (!initialised) {
+ initialise() ;
+ }
+
+ if (receiverQueue != null) {
+ try {
+ TextMessage msg = (TextMessage) queueReceiver.receive();
+ if (msg != null) {
+ System.out.println("*********************************************************");
+ System.out.println(msg.getText());
+ System.out.println("*********************************************************");
}
-
- if (receiverQueue != null) {
- try {
- TextMessage msg = (TextMessage) queueReceiver.receive();
- if (msg != null) {
- System.out.println("*********************************************************");
- System.out.println(msg.getText());
- System.out.println("*********************************************************");
- }
- } catch (final Exception ex) {
- cleanup() ;
- System.out.println(ex.getMessage()) ;
- }
+ } catch (final Exception ex) {
+ cleanup() ;
+ System.out.println(ex.getMessage()) ;
+ }
+ }
+
+ if (!initialised) {
+ System.out.println("Pausing before reinitialising") ;
+ try {
+ Thread.sleep(5000) ;
+ } catch (final InterruptedException ie) {
+ // do nothing
+ }
+ }
+ }
+
+ private void initialise()
+ {
+ try {
+ if (iniCtx == null) iniCtx = new InitialContext();
+ if (qcf == null) qcf = (QueueConnectionFactory) iniCtx.lookup("ConnectionFactory");
+ if (conn == null) {
+ conn = qcf.createQueueConnection();
+ conn.start();
+ }
+ receiverQueue = (Queue) iniCtx.lookup(receiveQueueName);
+ receiverSession = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+ queueReceiver = receiverSession.createReceiver(receiverQueue);
+ initialised = true ;
+ System.out.println("Initialised") ;
+ } catch (final Exception ex) {
+ cleanup() ;
+ }
+ }
+
+ public void cleanup() {
+ System.out.println("Closing connections");
+ queueReceiver = null ;
+ receiverSession = null ;
+ receiverQueue = null ;
+ if (receiverSession!=null) {
+ try {
+ receiverSession.close();
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
+ if (conn!=null) {
+ try {
+ conn.close() ;
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
+ conn = null ;
+ qcf = null ;
+ iniCtx = null ;
+ initialised = false ;
+ System.out.println("Closing completed");
+ }
+
+ public static void main(String[] args) {
+ final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+
+ if ((args.length > 0) && (args[0] != null)) {
+ receiver.receiveQueueName = args[0];
+ System.out.println("Receiving on: " + receiver.receiveQueueName );
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ receiver.cleanup() ;
}
-
- if (!initialised) {
- System.out.println("Pausing before reinitialising") ;
- try {
- Thread.sleep(5000) ;
- } catch (final InterruptedException ie) {
- // do nothing
- }
- }
- }
-
- private void initialise()
- {
+ }) ;
+ while (true) { // loop until I'm killed
+ receiver.receiveOne();
try {
- if (iniCtx == null) iniCtx = new InitialContext();
- if (qcf == null) qcf = (QueueConnectionFactory) iniCtx.lookup("ConnectionFactory");
- if (conn == null) {
- conn = qcf.createQueueConnection();
- conn.start();
- }
- receiverQueue = (Queue) iniCtx.lookup(receiveQueueName);
- receiverSession = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
- queueReceiver = receiverSession.createReceiver(receiverQueue);
- initialised = true ;
- System.out.println("Initialised") ;
- } catch (final Exception ex) {
- cleanup() ;
- }
- }
-
- public void cleanup() {
- queueReceiver = null ;
- receiverSession = null ;
- receiverQueue = null ;
- try {
- conn.stop() ;
- } catch (final Exception ex) {
- // Do nothing ;
- }
- conn = null ;
- qcf = null ;
- iniCtx = null ;
- initialised = false ;
- }
-
- public static void main(String[] args) {
- final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
-
- if ((args.length > 0) && (args[0] != null)) {
- receiver.receiveQueueName = args[0];
- System.out.println("Receiving on: " + receiver.receiveQueueName );
- }
- Runtime.getRuntime().addShutdownHook(new Thread() {
- public void run() {
- receiver.cleanup() ;
- }
- }) ;
- while (true) { // loop until I'm killed
- receiver.receiveOne();
- }
- }
+ Thread.sleep(500);
+ } catch (InterruptedException e) {break;}
+ }
+
+ } else {
+ System.out.println("Usage <queue-name>");
+ }
+ }
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/build.xml 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/build.xml 2007-10-23 16:31:38 UTC (rev 16022)
@@ -20,7 +20,7 @@
<target name="receive" depends="compile" description="runs Test JMS Receiver">
<echo>Runs Test JMS Receiver</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.transformxml2pojo.test.ReceiveJMSMessage" failonerror="true">
+ <java fork="no" classname="org.jboss.soa.esb.samples.quickstart.transformxml2pojo.test.ReceiveJMSMessage" failonerror="true">
<classpath refid="exec-classpath"/>
</java>
</target>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java 2007-10-23 16:23:17 UTC (rev 16021)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java 2007-10-23 16:31:38 UTC (rev 16022)
@@ -36,12 +36,13 @@
InitialContext iniCtx = null;
QueueConnectionFactory qcf = null;
String receiveQueueName = "queue/quickstart_simple_transformation_Response";
- private boolean initialised ;
+ private boolean initialised ;
- public ReceiveJMSMessage() {
-
- }
- public void receiveOne() {
+
+ public ReceiveJMSMessage() {
+
+ }
+ public void receiveOne() {
if (!initialised) {
initialise() ;
}
@@ -50,9 +51,9 @@
try {
TextMessage msg = (TextMessage) queueReceiver.receive();
if (msg != null) {
- System.out.println("*********************************************************");
- System.out.println(msg.getText());
- System.out.println("*********************************************************");
+ System.out.println("*********************************************************");
+ System.out.println(msg.getText());
+ System.out.println("*********************************************************");
}
} catch (final Exception ex) {
cleanup() ;
@@ -68,7 +69,7 @@
// do nothing
}
}
- }
+ }
private void initialise()
{
@@ -90,34 +91,51 @@
}
public void cleanup() {
+ System.out.println("Closing connections");
queueReceiver = null ;
receiverSession = null ;
receiverQueue = null ;
- try {
- conn.stop() ;
- } catch (final Exception ex) {
- // Do nothing ;
+ if (receiverSession!=null) {
+ try {
+ receiverSession.close();
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
}
+ if (conn!=null) {
+ try {
+ conn.close() ;
+ } catch (final Exception ex) {
+ // Do nothing ;
+ }
+ }
conn = null ;
qcf = null ;
iniCtx = null ;
initialised = false ;
+ System.out.println("Closing completed");
}
- public static void main(String[] args) {
- final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
-
- if ((args.length > 0) && (args[0] != null)) {
- receiver.receiveQueueName = args[0];
- System.out.println("Receiving on: " + receiver.receiveQueueName );
- }
- Runtime.getRuntime().addShutdownHook(new Thread() {
- public void run() {
- receiver.cleanup() ;
- }
- }) ;
- while (true) { // loop until I'm killed
- receiver.receiveOne();
- }
- }
+ public static void main(String[] args) {
+ final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+
+ if ((args.length > 0) && (args[0] != null)) {
+ receiver.receiveQueueName = args[0];
+ System.out.println("Receiving on: " + receiver.receiveQueueName );
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ receiver.cleanup() ;
+ }
+ }) ;
+ while (true) { // loop until I'm killed
+ receiver.receiveOne();
+ try {
+ Thread.sleep(500);
+ } catch (InterruptedException e) {break;}
+ }
+
+ } else {
+ System.out.println("Usage <queue-name>");
+ }
+ }
}
More information about the jboss-svn-commits
mailing list