[jboss-svn-commits] JBL Code SVN: r9034 - in labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners: gateway and 1 other directory.

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Fri Jan 26 02:55:59 EST 2007


Author: kurt.stam at jboss.com
Date: 2007-01-26 02:55:59 -0500 (Fri, 26 Jan 2007)
New Revision: 9034

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
Log:
Moved the definition of the gateway composer class from the action element in an an attribute of the gateway.

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/ListenerTagNames.java	2007-01-26 06:21:51 UTC (rev 9033)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/ListenerTagNames.java	2007-01-26 07:55:59 UTC (rev 9034)
@@ -61,6 +61,9 @@
     public static final String EXCEPTION_METHOD_TAG		    = "exceptionMethod";
     public static final String HTTP_ROUTER_ROUTE_URL        = "routeUrl";
     
+    /** Gateway Composer */
+    public static final String GATEWAY_COMPOSER_CLASS_TAG   = "composer-class";
+    public static final String GATEWAY_COMPOSER_METHOD_TAG  = "composer-process";
     /** Routing */
     public static final String DESTINATION_NAME_TAG         = "destination-name";
     /** Content Based Routing */

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java	2007-01-26 06:21:51 UTC (rev 9033)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java	2007-01-26 07:55:59 UTC (rev 9034)
@@ -445,20 +445,15 @@
 	{
 		try
 		{
-			// Look for first "action" element - only first one will be used
-			String tagName = ListenerTagNames.ACTION_ELEMENT_TAG;
-			ConfigTree actionElement = _config.getFirstChild(tagName);
 			String sProcessMethod = null;
-			if (null != actionElement)
+            _composerName = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_CLASS_TAG, null);
+			if (null != _composerName)
 			{ // class attribute
-				_composerName = _controller.obtainAtt(actionElement,
-						ListenerTagNames.ACTION_CLASS_TAG, null);
 				_composerClass = Class.forName(_composerName);
 				Constructor oConst = _composerClass.getConstructor(new Class[]
 				{ ConfigTree.class });
 				_composer = oConst.newInstance(_config);
-				tagName = ListenerTagNames.PROCESS_METHOD_TAG;
-				sProcessMethod = _controller.obtainAtt(actionElement, tagName, tagName);
+				sProcessMethod = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_METHOD_TAG, "process");
 			}
 			else
 			{

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2007-01-26 06:21:51 UTC (rev 9033)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2007-01-26 07:55:59 UTC (rev 9034)
@@ -238,21 +238,16 @@
 	{
 		try
 		{
-			// Look for first "action" element - only first one will be used
-			String tagName = ListenerTagNames.ACTION_ELEMENT_TAG;
-			ConfigTree actionElement = _config.getFirstChild(tagName);
-			String sProcessMethod = null;
-			if (null != actionElement)
-			{ // class attribute
-				_composerName = _controller.obtainAtt(actionElement,
-						ListenerTagNames.ACTION_CLASS_TAG, null);
-				_composerClass = Class.forName(_composerName);
-				Constructor oConst = _composerClass
-						.getConstructor(new Class[] { ConfigTree.class });
-				_composer = oConst.newInstance(_config);
-				tagName = ListenerTagNames.PROCESS_METHOD_TAG;
-				sProcessMethod = _controller.obtainAtt(_config, tagName, tagName);
-			}
+            String sProcessMethod = null;
+            _composerName = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_CLASS_TAG, null);
+            if (null != _composerName)
+            { // class attribute
+                _composerClass = Class.forName(_composerName);
+                Constructor oConst = _composerClass.getConstructor(new Class[]
+                { ConfigTree.class });
+                _composer = oConst.newInstance(_config);
+                sProcessMethod = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_METHOD_TAG, "process");
+            }
 			else
 			{
 				_composerName = PackageJmsMessageContents.class.getName();

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2007-01-26 06:21:51 UTC (rev 9033)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2007-01-26 07:55:59 UTC (rev 9034)
@@ -404,21 +404,16 @@
 	{
 		try
 		{
-			// Look for first "action" element - only first one will be used
-			String tagName = ListenerTagNames.ACTION_ELEMENT_TAG;
-			ConfigTree actionElement = _config.getFirstChild(tagName);
-			String sProcessMethod = null;
-			if (null != actionElement)
-			{ // class attribute
-				_composerName = _controller.obtainAtt(actionElement,
-						ListenerTagNames.ACTION_CLASS_TAG, null);
-				_composerClass = Class.forName(_composerName);
-				Constructor oConst = _composerClass
-						.getConstructor(new Class[] { ConfigTree.class });
-				_composer = oConst.newInstance(_config);
-				tagName = ListenerTagNames.PROCESS_METHOD_TAG;
-				sProcessMethod = _controller.obtainAtt(_config, tagName, tagName);
-			}
+            String sProcessMethod = null;
+            _composerName = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_CLASS_TAG, null);
+            if (null != _composerName)
+            { // class attribute
+                _composerClass = Class.forName(_composerName);
+                Constructor oConst = _composerClass.getConstructor(new Class[]
+                { ConfigTree.class });
+                _composer = oConst.newInstance(_config);
+                sProcessMethod = _config.getAttribute(ListenerTagNames.GATEWAY_COMPOSER_METHOD_TAG, "process");
+            }
 			else
 			{
 				_composerName = PackageRowContents.class.getName();




More information about the jboss-svn-commits mailing list