[jboss-svn-commits] JBL Code SVN: r8565 - in labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart: . moreaction moreaction/test
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Dec 22 17:23:30 EST 2006
Author: estebanschifman
Date: 2006-12-22 17:23:18 -0500 (Fri, 22 Dec 2006)
New Revision: 8565
Added:
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/CustomConfigAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/MyJMSListenerAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/StatefulAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/test/
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/Launcher.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/test/
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/test/SendJMSMessage.java
Log:
Rename package
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -1,31 +0,0 @@
-package quickstart;
-
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.message.Message;
-import java.util.Set;
-
-public class CustomConfigAction {
- protected ConfigTree _config;
- public CustomConfigAction(ConfigTree config) { _config = config; }
-
- public Message displayConfig(Message msg) {
- // Note: in and out message is being ignored
-
- Set<String> names = _config.getAttributeNames();
- System.out.println("****************************");
- for (String attrName : names) {
- String value = _config.getAttribute(attrName);
- System.out.println("Attribute: " + attrName + " Value: " + value);
- }
- System.out.println("****************************");
-
- ConfigTree[] subElements = _config.getAllChildren();
- // Note: even a sub-element can have attributes but trying to keep this simple
- System.out.println("############################");
- for (ConfigTree child : subElements) {
- System.out.println("SubElement: " + child.getName() + "Body: " + child.getWholeText());
- }
- System.out.println("############################");
- return msg;
- }
-}
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/Launcher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/Launcher.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/Launcher.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -1,81 +0,0 @@
-package quickstart;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.listeners.gateway.GatewayListenerController;
-import org.jboss.soa.esb.listeners.message.EsbListenerController;
-import org.jboss.soa.esb.listeners.message.EsbListenerControllerFactory;
-
-
-public class Launcher {
- private static Log log = LogFactory.getLog(Launcher.class);
-
- private EsbListenerController _esbListController;
- private GatewayListenerController _gatewayController;
-
-
-
- private Logger _logger = Logger.getLogger(Launcher.class);
-
- public static void main (String args[]) throws Exception {
-
- log.info("args passed into Launcher: " + args.length);
- for (int x=0; x<args.length; x++)
- log.info("arg[" + x + "]=" + args[x]);
-
-
- Launcher launcher = new Launcher();
-
- launcher.triggerListener(Long.valueOf(args[0]).longValue(), args[1], args[2]);
-
- }
-
- private void triggerListener(long runTime, String messageAwareConfigFile,
- String gatewayConfigFile) throws Exception{
- try
- {
-
- if (null != messageAwareConfigFile) {
- _logger.info("starting message aware listener with config file - " +
- messageAwareConfigFile);
- _esbListController = EsbListenerControllerFactory.getInstance(messageAwareConfigFile);
- }
- if (null != gatewayConfigFile) {
- _logger.info("starting gateway listener with config file - " +
- gatewayConfigFile);
- _gatewayController = new GatewayListenerController(gatewayConfigFile);
- new Thread(_gatewayController).start();
-
- Thread.sleep(2000);
- }
-
- System.out.println("**Listener Ready**");
-
-// This code is used to automatically shutdown the listeners which
-// might be useful for automated testing purposes. It is not needed
-// in the quickstart samples.
-// _logger.info("going to sleep now for " + runTime + " milliseconds...");
-// Thread.sleep(runTime);
-// if (null != messageAwareConfigFile) {
-// _logger.info("shutting down message aware listener...");
-// _esbListController.requestEnd();
-// }
-//
-// if (null != gatewayConfigFile) {
-// _logger.info("shutting down gateway listener...");
-// _gatewayController.requestEnd();
-// }
-
-
- }
- catch (Exception e) {
- _logger.error(e);
- throw(e);
- }
-
-
- }
-
-
-}
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -1,66 +0,0 @@
-package quickstart;
-
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.message.Header;
-import org.jboss.soa.esb.message.Body;
-import org.jboss.soa.esb.addressing.Call;
-import org.jboss.soa.esb.addressing.EPR;
-import org.apache.log4j.Logger;
-
-public class MyJMSListenerAction
-{
-
- protected ConfigTree _config;
-
- public MyJMSListenerAction(ConfigTree config) { _config = config; }
-
- public Message noOperation(Message message) { return message; }
-
- public Message process(Message message) {
- System.out.println("** Demonstrates the default method call if no process attribute is specified");
- return message;
- }
-
- public Message displayMessage(Message message) throws Exception{
- logHeader();
- System.out.println("Body: " + new String(message.getBody().getContents()));
- logFooter();
- return message;
- }
-
- public Message playWithMessage(Message message) throws Exception {
- Header msgHeader = message.getHeader();
- Body msgBody = message.getBody();
- Call theCall = msgHeader.getCall();
- EPR theEpr = theCall.getFrom();
- String contents = new String(msgBody.getContents());
- StringBuffer sb = new StringBuffer();
- sb.append("BEFORE\n");
- sb.append(contents);
- sb.append("\nAFTER");
- msgBody.setContents(sb.toString().getBytes());
- return message;
- }
-
- public void exceptionHandler(Message message, Throwable exception) {
- logHeader();
- System.out.println("!ERROR!");
- System.out.println(exception.getMessage());
- System.out.println("For Message: ");
- System.out.println(message.getBody().getContents());
- logFooter();
- }
-
-
- // This makes it easier to read on the console
- private void logHeader() {
- System.out.println("\n&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
- }
- private void logFooter() {
- System.out.println("&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&\n");
- }
-
-
-}
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -1,45 +0,0 @@
-package quickstart;
-
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.message.Message;
-
-public class StatefulAction {
- protected ConfigTree _config;
- int cnt = 0;
- public StatefulAction(ConfigTree config) {
- System.out.println("\n\n!!Constructor - " + this.getClass().getName() + "!!\n");
- cnt++; // 1
- _config = config;
- }
-
- public Message methodOne(Message msg) throws Exception {
- cnt++; // 2
- System.out.println("methodOne: " + cnt);
- return msg;
- }
- public Message methodTwo(Message msg) throws Exception {
- cnt++; // 3
- System.out.println("methodTwo: " + cnt);
- return msg;
- }
- public Message displayCount(Message msg) throws Exception {
- System.out.println("\n\n displayCount cnt=" + cnt + "\n");
- return msg;
- }
- public void exceptionHandler(Message message, Throwable exception) {
- logHeader();
- System.out.println("!ERROR!");
- System.out.println(exception.getMessage());
- System.out.println("For Message: ");
- System.out.println(message.getBody().getContents());
- logFooter();
- }
-
- // This makes it easier to read on the console
- private void logHeader() {
- System.out.println("\n&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
- }
- private void logFooter() {
- System.out.println("&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&\n");
- }
-}
Copied: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/CustomConfigAction.java (from rev 8564, labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java)
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/CustomConfigAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/CustomConfigAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -0,0 +1,31 @@
+package quickstart.moreaction;
+
+import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.message.Message;
+import java.util.Set;
+
+public class CustomConfigAction {
+ protected ConfigTree _config;
+ public CustomConfigAction(ConfigTree config) { _config = config; }
+
+ public Message displayConfig(Message msg) {
+ // Note: in and out message is being ignored
+
+ Set<String> names = _config.getAttributeNames();
+ System.out.println("****************************");
+ for (String attrName : names) {
+ String value = _config.getAttribute(attrName);
+ System.out.println("Attribute: " + attrName + " Value: " + value);
+ }
+ System.out.println("****************************");
+
+ ConfigTree[] subElements = _config.getAllChildren();
+ // Note: even a sub-element can have attributes but trying to keep this simple
+ System.out.println("############################");
+ for (ConfigTree child : subElements) {
+ System.out.println("SubElement: " + child.getName() + "Body: " + child.getWholeText());
+ }
+ System.out.println("############################");
+ return msg;
+ }
+}
Copied: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/MyJMSListenerAction.java (from rev 8564, labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java)
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/MyJMSListenerAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/MyJMSListenerAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -0,0 +1,65 @@
+package quickstart.moreaction;
+
+import org.jboss.soa.esb.addressing.Call;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.message.Body;
+import org.jboss.soa.esb.message.Header;
+import org.jboss.soa.esb.message.Message;
+
+public class MyJMSListenerAction
+{
+
+ protected ConfigTree _config;
+
+ public MyJMSListenerAction(ConfigTree config) { _config = config; }
+
+ public Message noOperation(Message message) { return message; }
+
+ public Message process(Message message) {
+ System.out.println("** Demonstrates the default method call if no process attribute is specified");
+ return message;
+ }
+
+ public Message displayMessage(Message message) throws Exception{
+ logHeader();
+ System.out.println("Body: " + new String(message.getBody().getContents()));
+ logFooter();
+ return message;
+ }
+
+ public Message playWithMessage(Message message) throws Exception {
+ Header msgHeader = message.getHeader();
+ Call theCall = msgHeader.getCall();
+ @SuppressWarnings("unused")
+ EPR theEpr = theCall.getFrom();
+ Body msgBody = message.getBody();
+ String contents = new String(msgBody.getContents());
+ StringBuffer sb = new StringBuffer();
+ sb.append("BEFORE\n");
+ sb.append(contents);
+ sb.append("\nAFTER");
+ msgBody.setContents(sb.toString().getBytes());
+ return message;
+ }
+
+ public void exceptionHandler(Message message, Throwable exception) {
+ logHeader();
+ System.out.println("!ERROR!");
+ System.out.println(exception.getMessage());
+ System.out.println("For Message: ");
+ System.out.println(message.getBody().getContents());
+ logFooter();
+ }
+
+
+ // This makes it easier to read on the console
+ private void logHeader() {
+ System.out.println("\n&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
+ }
+ private void logFooter() {
+ System.out.println("&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&\n");
+ }
+
+
+}
\ No newline at end of file
Copied: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/StatefulAction.java (from rev 8564, labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java)
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/StatefulAction.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/StatefulAction.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -0,0 +1,45 @@
+package quickstart.moreaction;
+
+import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.message.Message;
+
+public class StatefulAction {
+ protected ConfigTree _config;
+ int cnt = 0;
+ public StatefulAction(ConfigTree config) {
+ System.out.println("\n\n!!Constructor - " + this.getClass().getName() + "!!\n");
+ cnt++; // 1
+ _config = config;
+ }
+
+ public Message methodOne(Message msg) throws Exception {
+ cnt++; // 2
+ System.out.println("methodOne: " + cnt);
+ return msg;
+ }
+ public Message methodTwo(Message msg) throws Exception {
+ cnt++; // 3
+ System.out.println("methodTwo: " + cnt);
+ return msg;
+ }
+ public Message displayCount(Message msg) throws Exception {
+ System.out.println("\n\n displayCount cnt=" + cnt + "\n");
+ return msg;
+ }
+ public void exceptionHandler(Message message, Throwable exception) {
+ logHeader();
+ System.out.println("!ERROR!");
+ System.out.println(exception.getMessage());
+ System.out.println("For Message: ");
+ System.out.println(message.getBody().getContents());
+ logFooter();
+ }
+
+ // This makes it easier to read on the console
+ private void logHeader() {
+ System.out.println("\n&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
+ }
+ private void logFooter() {
+ System.out.println("&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&\n");
+ }
+}
Copied: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/test (from rev 8564, labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/test)
Modified: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/test/SendJMSMessage.java 2006-12-22 21:28:58 UTC (rev 8564)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/moreaction/test/SendJMSMessage.java 2006-12-22 22:23:18 UTC (rev 8565)
@@ -1,19 +1,15 @@
-package quickstart.test;
+package quickstart.moreaction.test;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
import javax.jms.JMSException;
-import javax.jms.QueueConnectionFactory;
+import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
-import javax.jms.QueueSession;
+import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
-import javax.jms.ObjectMessage;
+import javax.jms.QueueSession;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-
public class SendJMSMessage {
QueueConnection conn;
QueueSession session;
More information about the jboss-svn-commits
mailing list