[jboss-svn-commits] JBL Code SVN: r12278 - in labs/jbossesb/trunk/product/samples/quickstarts: fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test and 2 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Jun 1 05:52:33 EDT 2007
Author: kevin.conner at jboss.com
Date: 2007-06-01 05:52:32 -0400 (Fri, 01 Jun 2007)
New Revision: 12278
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/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java
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/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java
Log:
Fix ReceiveJMSMessage: JBESB-582
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-06-01 02:42:44 UTC (rev 12277)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/test/ReceiveJMSMessage.java 2007-06-01 09:52:32 UTC (rev 12278)
@@ -18,58 +18,106 @@
* (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
-
- public ReceiveJMSMessage() {
-
- }
- public void 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);
- TextMessage msg = (TextMessage) queueReceiver.receive(2000);
- if (msg != null) {
- System.out.println("*********************************************************");
- System.out.println(msg);
- System.out.println("*********************************************************");
- }
- } catch (Exception e) {
- System.out.println(e);
- }
- }
- public static void main(String[] args) {
- ReceiveJMSMessage receiver = new ReceiveJMSMessage();
-
- if(args[0] != null) {
- receiver.receiveQueueName = args[0];
- System.out.println("Receiving on: " + receiver.receiveQueueName );
- }
- 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() {
+ 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();
+ }
+ }
+}
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-06-01 02:42:44 UTC (rev 12277)
+++ labs/jbossesb/trunk/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/ReceiveJMSMessage.java 2007-06-01 09:52:32 UTC (rev 12278)
@@ -36,38 +36,86 @@
InitialContext iniCtx = null;
QueueConnectionFactory qcf = null;
String receiveQueueName = "queue/D"; // Default to queue/D
+ private boolean initialised ;
public ReceiveJMSMessage() {
}
public void 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);
- TextMessage msg = (TextMessage) queueReceiver.receive(2000);
- if (msg != null) {
+ if (!initialised) {
+ initialise() ;
+ }
+
+ if (receiverQueue != null) {
+ try {
+ TextMessage msg = (TextMessage) queueReceiver.receive();
+ if (msg != null) {
System.out.println("*********************************************************");
- System.out.println(msg);
+ System.out.println(msg.getText());
System.out.println("*********************************************************");
- }
- } catch (Exception e) {
- System.out.println(e);
- }
+ }
+ } 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) {
- ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+ final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
- if(args[0] != null) {
+ 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();
}
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-06-01 02:42:44 UTC (rev 12277)
+++ labs/jbossesb/trunk/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/ReceiveJMSMessage.java 2007-06-01 09:52:32 UTC (rev 12278)
@@ -36,38 +36,86 @@
InitialContext iniCtx = null;
QueueConnectionFactory qcf = null;
String receiveQueueName = "queue/D"; // Default to queue/D
+ private boolean initialised ;
public ReceiveJMSMessage() {
}
public void 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);
- TextMessage msg = (TextMessage) queueReceiver.receive(2000);
- if (msg != null) {
+ if (!initialised) {
+ initialise() ;
+ }
+
+ if (receiverQueue != null) {
+ try {
+ TextMessage msg = (TextMessage) queueReceiver.receive();
+ if (msg != null) {
System.out.println("*********************************************************");
- System.out.println(msg);
+ System.out.println(msg.getText());
System.out.println("*********************************************************");
- }
- } catch (Exception e) {
- System.out.println(e);
- }
+ }
+ } 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) {
- ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+ final ReceiveJMSMessage receiver = new ReceiveJMSMessage();
- if(args[0] != null) {
+ 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();
}
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-06-01 02:42:44 UTC (rev 12277)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/test/ReceiveJMSMessage.java 2007-06-01 09:52:32 UTC (rev 12278)
@@ -35,33 +35,87 @@
QueueReceiver queueReceiver = null;
InitialContext iniCtx = null;
QueueConnectionFactory qcf = null;
+ String receiveQueueName = "queue/quickstart_simple_transformation_Response";
+ private boolean initialised ;
+
public ReceiveJMSMessage() {
}
public void receiveOne() {
- try {
- if (iniCtx == null) iniCtx = new InitialContext();
- if (qcf == null) qcf = (QueueConnectionFactory) iniCtx.lookup("ConnectionFactory");
- if (conn == null) {
- conn = qcf.createQueueConnection();
- conn.start();
- }
- String responseQueueName = "queue/quickstart_simple_transformation_Response";
- receiverQueue = (Queue) iniCtx.lookup(responseQueueName);
- receiverSession = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
- queueReceiver = receiverSession.createReceiver(receiverQueue);
- TextMessage msg = (TextMessage) queueReceiver.receive(2000);
- if (msg != null) {
+ if (!initialised) {
+ initialise() ;
+ }
+
+ if (receiverQueue != null) {
+ try {
+ TextMessage msg = (TextMessage) queueReceiver.receive();
+ if (msg != null) {
System.out.println("*********************************************************");
- System.out.println(msg);
+ System.out.println(msg.getText());
System.out.println("*********************************************************");
- }
- } catch (Exception e) {
- System.out.println(e);
- }
+ }
+ } 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) {
- ReceiveJMSMessage receiver = new ReceiveJMSMessage();
+ 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();
}
More information about the jboss-svn-commits
mailing list