[jboss-cvs] jboss-jms/tests/src/org/jboss/test/messaging/core/local ...
Timothy Fox
tim.fox at jboss.com
Mon Jul 17 13:14:51 EDT 2006
User: timfox
Date: 06/07/17 13:14:51
Modified: tests/src/org/jboss/test/messaging/core/local
NonRecoverableQueueTest.java
NonRecoverableSubscriptionTest.java
RecoverableQueueTest.java
RecoverableSubscriptionTest.java
SubscriptionWithFilterTest.java
Log:
Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
Revision Changes Path
1.7 +5 -3 jboss-jms/tests/src/org/jboss/test/messaging/core/local/NonRecoverableQueueTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: NonRecoverableQueueTest.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/local/NonRecoverableQueueTest.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -b -r1.6 -r1.7
--- NonRecoverableQueueTest.java 27 Jun 2006 19:44:40 -0000 1.6
+++ NonRecoverableQueueTest.java 17 Jul 2006 17:14:51 -0000 1.7
@@ -24,14 +24,16 @@
import org.jboss.test.messaging.core.local.base.QueueTestBase;
import org.jboss.messaging.core.local.Queue;
+import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+
/**
* Tests a non-recoverable queue that doesn't accept reliable messages.
*
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @version <tt>$Revision: 1.6 $</tt>
+ * @version <tt>$Revision: 1.7 $</tt>
*
- * $Id: NonRecoverableQueueTest.java,v 1.6 2006/06/27 19:44:40 timfox Exp $
+ * $Id: NonRecoverableQueueTest.java,v 1.7 2006/07/17 17:14:51 timfox Exp $
*/
public class NonRecoverableQueueTest extends QueueTestBase
{
@@ -54,7 +56,7 @@
{
super.setUp();
- channel = new Queue(1, ms, pm, null, false, 100, 20, 10);
+ channel = new Queue(1, ms, pm, null, false, 100, 20, 10, new QueuedExecutor());
}
public void tearDown() throws Exception
1.3 +5 -3 jboss-jms/tests/src/org/jboss/test/messaging/core/local/NonRecoverableSubscriptionTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: NonRecoverableSubscriptionTest.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/local/NonRecoverableSubscriptionTest.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -b -r1.2 -r1.3
--- NonRecoverableSubscriptionTest.java 27 Jun 2006 19:44:40 -0000 1.2
+++ NonRecoverableSubscriptionTest.java 17 Jul 2006 17:14:51 -0000 1.3
@@ -24,12 +24,14 @@
import org.jboss.messaging.core.local.CoreSubscription;
import org.jboss.test.messaging.core.local.base.QueueTestBase;
+import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+
/**
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @version <tt>$Revision: 1.2 $</tt>
+ * @version <tt>$Revision: 1.3 $</tt>
*
- * $Id: NonRecoverableSubscriptionTest.java,v 1.2 2006/06/27 19:44:40 timfox Exp $
+ * $Id: NonRecoverableSubscriptionTest.java,v 1.3 2006/07/17 17:14:51 timfox Exp $
*/
public class NonRecoverableSubscriptionTest extends QueueTestBase
{
@@ -52,7 +54,7 @@
{
super.setUp();
- channel = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, null);
+ channel = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, new QueuedExecutor(), null);
log.debug("setup done");
}
1.18 +6 -4 jboss-jms/tests/src/org/jboss/test/messaging/core/local/RecoverableQueueTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: RecoverableQueueTest.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/local/RecoverableQueueTest.java,v
retrieving revision 1.17
retrieving revision 1.18
diff -u -b -r1.17 -r1.18
--- RecoverableQueueTest.java 27 Jun 2006 19:44:40 -0000 1.17
+++ RecoverableQueueTest.java 17 Jul 2006 17:14:51 -0000 1.18
@@ -25,12 +25,14 @@
import org.jboss.messaging.core.plugin.SimpleMessageStore;
import org.jboss.test.messaging.core.local.base.QueueTestBase;
+import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+
/**
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @version <tt>$Revision: 1.17 $</tt>
+ * @version <tt>$Revision: 1.18 $</tt>
*
- * $Id: RecoverableQueueTest.java,v 1.17 2006/06/27 19:44:40 timfox Exp $
+ * $Id: RecoverableQueueTest.java,v 1.18 2006/07/17 17:14:51 timfox Exp $
*/
public class RecoverableQueueTest extends QueueTestBase
{
@@ -56,7 +58,7 @@
ms = new SimpleMessageStore("s14");
- channel = new Queue(1, ms, pm, null, true, 100, 20, 10);
+ channel = new Queue(1, ms, pm, null, true, 100, 20, 10, new QueuedExecutor());
tr.start(pm);
@@ -82,7 +84,7 @@
public void recoverChannel() throws Exception
{
- channel = new Queue(1, ms, pm, null, true, 100, 20, 10);
+ channel = new Queue(1, ms, pm, null, true, 100, 20, 10, new QueuedExecutor());
}
// Public --------------------------------------------------------
1.3 +5 -3 jboss-jms/tests/src/org/jboss/test/messaging/core/local/RecoverableSubscriptionTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: RecoverableSubscriptionTest.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/local/RecoverableSubscriptionTest.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -b -r1.2 -r1.3
--- RecoverableSubscriptionTest.java 27 Jun 2006 19:44:40 -0000 1.2
+++ RecoverableSubscriptionTest.java 17 Jul 2006 17:14:51 -0000 1.3
@@ -26,12 +26,14 @@
import org.jboss.messaging.core.plugin.SimpleMessageStore;
import org.jboss.test.messaging.core.base.ChannelTestBase;
+import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+
/**
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @version <tt>$Revision: 1.2 $</tt>
+ * @version <tt>$Revision: 1.3 $</tt>
*
- * $Id: RecoverableSubscriptionTest.java,v 1.2 2006/06/27 19:44:40 timfox Exp $
+ * $Id: RecoverableSubscriptionTest.java,v 1.3 2006/07/17 17:14:51 timfox Exp $
*/
public class RecoverableSubscriptionTest extends ChannelTestBase
{
@@ -63,7 +65,7 @@
tr.start(tl);
- channel = new CoreSubscription(123, null, ms, tl, null, true, 100, 20, 10, null);
+ channel = new CoreSubscription(123, null, ms, tl, null, true, 100, 20, 10, new QueuedExecutor(), null);
log.debug("setup done");
1.3 +6 -4 jboss-jms/tests/src/org/jboss/test/messaging/core/local/SubscriptionWithFilterTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: SubscriptionWithFilterTest.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/local/SubscriptionWithFilterTest.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -b -r1.2 -r1.3
--- SubscriptionWithFilterTest.java 27 Jun 2006 19:44:40 -0000 1.2
+++ SubscriptionWithFilterTest.java 17 Jul 2006 17:14:51 -0000 1.3
@@ -33,14 +33,16 @@
import org.jboss.test.messaging.MessagingTestCase;
import org.jboss.test.messaging.tools.jmx.ServiceContainer;
+import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+
/**
*
* A SubscriptionWithFilterTest.
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*
- * $Id: SubscriptionWithFilterTest.java,v 1.2 2006/06/27 19:44:40 timfox Exp $
+ * $Id: SubscriptionWithFilterTest.java,v 1.3 2006/07/17 17:14:51 timfox Exp $
*/
public class SubscriptionWithFilterTest extends MessagingTestCase
{
@@ -87,7 +89,7 @@
{
Filter f = new SimpleFilter(3);
- CoreSubscription sub = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, f);
+ CoreSubscription sub = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, new QueuedExecutor(), f);
Message m1 = new CoreMessage(1, false, 0, 0, (byte)0, null, null, 0);
Message m2 = new CoreMessage(2, false, 0, 0, (byte)0, null, null, 0);
@@ -105,7 +107,7 @@
public void testWithoutFilter()
{
- CoreSubscription sub = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, null);
+ CoreSubscription sub = new CoreSubscription(123, null, ms, pm, null, false, 100, 20, 10, new QueuedExecutor(), null);
Message m1 = new CoreMessage(1, false, 0, 0, (byte)0, null, null, 0);
Message m2 = new CoreMessage(2, false, 0, 0, (byte)0, null, null, 0);
More information about the jboss-cvs-commits
mailing list