[jboss-svn-commits] JBL Code SVN: r6151 - in labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb: listeners util
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Mon Sep 11 14:33:57 EDT 2006
Author: tfennelly
Date: 2006-09-11 14:33:51 -0400 (Mon, 11 Sep 2006)
New Revision: 6151
Added:
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListener-Config-01.xml
Modified:
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/DirectoryPollerUnitTest.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListenerUnitTest.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/SqlTablePollerUnitTest.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/ListenersManagerExecThread.java
labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java
Log:
Chained actions stuff
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/DirectoryPollerUnitTest.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/DirectoryPollerUnitTest.java 2006-09-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/DirectoryPollerUnitTest.java 2006-09-11 18:33:51 UTC (rev 6151)
@@ -42,7 +42,7 @@
// This should fail
DirectoryPoller dirPoller = null;
try {
- dirPoller = new DirectoryPoller(null,null);
+ dirPoller = new DirectoryPoller(null,null, null);
fail("GpListener should fail with empty constructor string");
} catch (Exception e) {
}
Added: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListener-Config-01.xml
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListener-Config-01.xml 2006-09-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListener-Config-01.xml 2006-09-11 18:33:51 UTC (rev 6151)
@@ -0,0 +1,31 @@
+<ListenerConfig
+ command-queue-class="org.jboss.soa.esb.command.InMemoryCommandQueue"
+ command-queue-name="test-queue"
+>
+
+ <ListenerConfig
+ listenerClass="org.jboss.soa.esb.util.MockPoller"
+ actions="String-To-Long, Long-To-Date, Route-To-Nowhere"
+ maxThreads="1"
+ >
+ </ListenerConfig>
+
+ <Actions>
+ <!--
+ Under the new architecture I think these will be equivalent to "Contracts Definitions"?
+ -->
+ <Action name="String-To-Long" handler="StringToLongConverter" />
+ <Action name="Long-To-Date" handler="LongToDateConverter" />
+ <Action name="Route-To-Nowhere" handler="ToNowhereRouter" />
+
+ <HandlerAliases>
+ <!--
+ Under the new architecture I think these will be equivalent to "Services"? The alias "name" being like the Service URN.
+ -->
+ <Alias name="StringToLongConverter" class="org.jboss.soa.esb.actions.StringToLongConverter" />
+ <Alias name="LongToDateConverter" class="org.jboss.soa.esb.actions.LongToDateConverter" />
+ <Alias name="ToNowhereRouter" class="org.jboss.soa.esb.actions.ToNowhereRouter" />
+ </HandlerAliases>
+ </Actions>
+
+</ListenerConfig>
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListenerUnitTest.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListenerUnitTest.java 2006-09-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/GpListenerUnitTest.java 2006-09-11 18:33:51 UTC (rev 6151)
@@ -21,7 +21,14 @@
*/
package org.jboss.soa.esb.listeners;
+import java.util.Date;
+
+import org.jboss.soa.esb.actions.ToNowhereRouter;
+import org.jboss.soa.esb.command.InMemoryCommandQueue;
import org.jboss.soa.esb.common.tests.BaseTest;
+import org.jboss.soa.esb.helpers.DomElement;
+import org.jboss.soa.esb.util.ListenersManagerExecThread;
+import org.jboss.soa.esb.util.MockPoller;
/**
* Test the GpListener
@@ -50,7 +57,29 @@
-
-
-
+ public void test_newGpListener() throws Exception {
+ DomElement config = DomElement.fromInputStream(getClass().getResourceAsStream("GpListener-Config-01.xml"));
+ GpListener listenerManager = new GpListener(config);
+ ListenersManagerExecThread execThread = new ListenersManagerExecThread(listenerManager);
+ long currentTimeInMillis = System.currentTimeMillis();
+
+ ToNowhereRouter.objects.clear();
+
+ // Start the listener...
+ execThread.start();
+
+ // Stick the current time in as a string...
+ MockPoller.addToQueue("" + currentTimeInMillis);
+ Thread.sleep(500);
+
+ // Send a shutdown command to the listener...
+ InMemoryCommandQueue.getQueue("test-queue").addCommand("shutdown");
+ execThread.assertShutdownOK(10000);
+
+ // Check did the "payload" get processed...
+ assertEquals(1, ToNowhereRouter.objects.size());
+ Object date = ToNowhereRouter.objects.get(0);
+ assertTrue(date instanceof Date);
+ assertEquals(new Date(currentTimeInMillis), date);
+ }
}
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/SqlTablePollerUnitTest.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/SqlTablePollerUnitTest.java 2006-09-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/SqlTablePollerUnitTest.java 2006-09-11 18:33:51 UTC (rev 6151)
@@ -41,7 +41,7 @@
// This should fail
SqlTablePoller sqlPoller = null;
try {
- sqlPoller = new SqlTablePoller(null, null);
+ sqlPoller = new SqlTablePoller(null, null, null);
fail("SqlTablePoller should fail with empty constructor string");
} catch (Exception e) {
}
Modified: labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/ListenersManagerExecThread.java
===================================================================
--- labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/ListenersManagerExecThread.java 2006-09-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/ListenersManagerExecThread.java 2006-09-11 18:33:51 UTC (rev 6151)
@@ -48,7 +48,7 @@
*/
public void asserttInException() {
if(listenersManager.getState() != GpListener.State.Exception_thrown) {
- String errorMsg = "ListenerManager not in Exception state. Listener Manager Thread: " + this.getName();
+ String errorMsg = "GpListener not in Exception state. Listener Manager Thread: " + this.getName();
logger.error(errorMsg);
TestCase.fail(errorMsg);
}
@@ -59,7 +59,7 @@
*/
public void assertNotInException() {
if(listenersManager.getState() == GpListener.State.Exception_thrown) {
- String errorMsg = "ListenerManager in Exception state. See log. Listener Manager Thread: " + this.getName();
+ String errorMsg = "GpListener in Exception state. See log. Listener Manager Thread: " + this.getName();
logger.error(errorMsg, listenersManager.getState().getException());
TestCase.fail(errorMsg);
}
@@ -83,7 +83,7 @@
logger.error("Thread interupt...", e);
}
}
- String errorMsg = "ListenerManager failed to shutdown as requested. Waited for " + maxWait + "ms. Listener Manager Thread: " + this.getName();
+ String errorMsg = "GpListener failed to shutdown as requested. Waited for " + maxWait + "ms. Listener Manager Thread: " + this.getName();
logger.error(errorMsg);
TestCase.fail(errorMsg);
}
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-11 18:32:57 UTC (rev 6150)
+++ labs/jbossesb/workspace/tfennelly/product/core/listeners/tests/src/org/jboss/soa/esb/util/MockPoller.java 2006-09-11 18:33:51 UTC (rev 6151)
@@ -5,6 +5,7 @@
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
+import org.jboss.soa.esb.actions.ActionDefinitionFactory;
import org.jboss.soa.esb.helpers.DomElement;
import org.jboss.soa.esb.listeners.AbstractPoller;
import org.jboss.soa.esb.listeners.GpListener;
@@ -19,8 +20,8 @@
private static Queue queue = new ConcurrentLinkedQueue<Object>();
- public MockPoller(GpListener p_oDad, DomElement p_oParms) throws Exception {
- super(p_oDad, p_oParms);
+ public MockPoller(GpListener p_oDad, DomElement p_oParms, ActionDefinitionFactory actionDefinitionFactory) throws Exception {
+ super(p_oDad, p_oParms, actionDefinitionFactory);
}
/**
More information about the jboss-svn-commits
mailing list