[jboss-svn-commits] JBL Code SVN: r6229 - in labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb: actions util
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Thu Sep 14 11:21:54 EDT 2006
Author: tfennelly
Date: 2006-09-14 11:21:47 -0400 (Thu, 14 Sep 2006)
New Revision: 6229
Added:
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/BaseTestActionProcessor.java
Modified:
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/LongToDateConverter.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/SmooksTransformActionFuncTest.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/StringToLongConverter.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor1.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor2.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor3.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/ToNowhereRouter.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java
Log:
ActionProcessor pipeline model changes
Added: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/BaseTestActionProcessor.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/BaseTestActionProcessor.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/BaseTestActionProcessor.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -0,0 +1,53 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.soa.esb.actions;
+
+import java.io.Serializable;
+
+/**
+ *
+ * @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
+ * @since Version 4.0
+ */
+public abstract class BaseTestActionProcessor implements ActionProcessor {
+
+ /* (non-Javadoc)
+ * @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
+ */
+ public abstract Object process(Object message) throws ActionProcessingException;
+
+ /* (non-Javadoc)
+ * @see org.jboss.soa.esb.actions.ActionProcessor#getOkNotification(java.lang.Object)
+ */
+ public Serializable getOkNotification(Object message) {
+ return "OK: " + message;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.soa.esb.actions.ActionProcessor#getErrorNotification(java.lang.Object)
+ */
+ public Serializable getErrorNotification(Object message) {
+ return "ERROR: " + message;
+ }
+
+}
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/LongToDateConverter.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/LongToDateConverter.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/LongToDateConverter.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -29,7 +29,7 @@
* @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
* @since Version 4.0
*/
-public class LongToDateConverter implements ActionProcessor {
+public class LongToDateConverter extends BaseTestActionProcessor {
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#processAction(java.lang.Object)
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/SmooksTransformActionFuncTest.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/SmooksTransformActionFuncTest.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/SmooksTransformActionFuncTest.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -9,7 +9,7 @@
public class SmooksTransformActionFuncTest extends TestCase {
public void test() throws Exception {
- DomElement config = DomElement.fromInputStream(getClass().getResourceAsStream("SmooksTransformActionListener-Config-01.xml"));
+ DomElement config = DomElement.fromInputStream(getClass().getResourceAsStream("SmooksTransformAction-Config-01.xml"));
GpListener listenerManager = new GpListener(config);
ListenersManagerExecThread execThread = new ListenersManagerExecThread(listenerManager);
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/StringToLongConverter.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/StringToLongConverter.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/StringToLongConverter.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -27,7 +27,7 @@
* @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
* @since Version 4.0
*/
-public class StringToLongConverter implements ActionProcessor {
+public class StringToLongConverter extends BaseTestActionProcessor {
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#processAction(java.lang.Object)
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor1.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor1.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor1.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -32,7 +32,7 @@
* @since Version 4.0
*/
-public class TestActionProcessor1 implements ActionProcessor {
+public class TestActionProcessor1 extends BaseTestActionProcessor {
public String name;
public List<KeyValuePair> properties;
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor2.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor2.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor2.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -28,7 +28,7 @@
* @since Version 4.0
*/
-public class TestActionProcessor2 implements ActionProcessor {
+public class TestActionProcessor2 extends BaseTestActionProcessor {
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#processAction(java.lang.Object)
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor3.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor3.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/TestActionProcessor3.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -28,7 +28,7 @@
* @since Version 4.0
*/
-public class TestActionProcessor3 implements ActionProcessor {
+public class TestActionProcessor3 extends BaseTestActionProcessor {
public TestActionProcessor3(String name) {
System.out.println("Instantiate action handler: " + name);
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/ToNowhereRouter.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/ToNowhereRouter.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/actions/ToNowhereRouter.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -30,7 +30,7 @@
* @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
* @since Version 4.0
*/
-public class ToNowhereRouter implements ActionProcessor {
+public class ToNowhereRouter extends BaseTestActionProcessor {
public static List objects = new ArrayList();
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java 2006-09-14 15:21:01 UTC (rev 6228)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java 2006-09-14 15:21:47 UTC (rev 6229)
@@ -61,9 +61,16 @@
}
@Override
- protected Object preProcess(Object actionObject) throws Exception {
+ protected Object preProcess(Object actionObject) {
// Called by the AbstractPoller for each of the objects returned to it be the above pollForCandidates method.
// Just return the object to be processed by the action class that's configured on the listener.
return actionObject;
}
+
+ /* (non-Javadoc)
+ * @see org.jboss.soa.esb.listeners.AbstractListener#close()
+ */
+ @Override
+ protected void close() {
+ }
}
More information about the jboss-svn-commits
mailing list