[jboss-cvs] JBoss Messaging SVN: r7316 - trunk/tests/src/org/jboss/messaging/tests/integration/client.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2009-06-12 05:22:20 -0400 (Fri, 12 Jun 2009)
New Revision: 7316

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerCloseTest.java
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientProducerCloseTest.java
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionCloseTest.java
   trunk/tests/src/org/jboss/messaging/tests/integration/client/MessagePriorityTest.java
   trunk/tests/src/org/jboss/messaging/tests/integration/client/RedeliveryConsumerTest.java
Log:
Fixed client tests that were assuming invm accpetor

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerCloseTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerCloseTest.java	2009-06-12 09:01:17 UTC (rev 7315)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerCloseTest.java	2009-06-12 09:22:20 UTC (rev 7316)
@@ -33,6 +33,7 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.config.impl.ConfigurationImpl;
 import org.jboss.messaging.core.exception.MessagingException;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
 import org.jboss.messaging.core.server.Messaging;
 import org.jboss.messaging.core.server.MessagingServer;
@@ -108,6 +109,7 @@
       super.setUp();
 
       Configuration config = new ConfigurationImpl();
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
       config.setSecurityEnabled(false);
       server = Messaging.newMessagingServer(config, false);
       server.start();

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientProducerCloseTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientProducerCloseTest.java	2009-06-12 09:01:17 UTC (rev 7315)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientProducerCloseTest.java	2009-06-12 09:22:20 UTC (rev 7316)
@@ -31,6 +31,7 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.config.impl.ConfigurationImpl;
 import org.jboss.messaging.core.exception.MessagingException;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
 import org.jboss.messaging.core.server.Messaging;
 import org.jboss.messaging.core.server.MessagingServer;
@@ -84,8 +85,8 @@
    protected void setUp() throws Exception
    {
       super.setUp();
-
       Configuration config = new ConfigurationImpl();
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
       config.setSecurityEnabled(false);
       server = Messaging.newMessagingServer(config, false);
       server.start();

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionCloseTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionCloseTest.java	2009-06-12 09:01:17 UTC (rev 7315)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionCloseTest.java	2009-06-12 09:22:20 UTC (rev 7316)
@@ -38,6 +38,7 @@
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.config.impl.ConfigurationImpl;
 import org.jboss.messaging.core.exception.MessagingException;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
 import org.jboss.messaging.core.server.Messaging;
 import org.jboss.messaging.core.server.MessagingServer;
@@ -258,8 +259,10 @@
       super.setUp();
 
       Configuration config = new ConfigurationImpl();
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
       config.setSecurityEnabled(false);
       server = Messaging.newMessagingServer(config, false);
+      
       server.start();
    }
 

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/MessagePriorityTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/MessagePriorityTest.java	2009-06-12 09:01:17 UTC (rev 7315)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/MessagePriorityTest.java	2009-06-12 09:22:20 UTC (rev 7316)
@@ -33,6 +33,7 @@
 import org.jboss.messaging.core.config.Configuration;
 import org.jboss.messaging.core.config.TransportConfiguration;
 import org.jboss.messaging.core.config.impl.ConfigurationImpl;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
 import org.jboss.messaging.core.server.Messaging;
 import org.jboss.messaging.core.server.MessagingServer;
@@ -222,6 +223,7 @@
       super.setUp();
 
       Configuration config = new ConfigurationImpl();
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
       config.setSecurityEnabled(false);
       server = Messaging.newMessagingServer(config, false);
       server.start();

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/RedeliveryConsumerTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/RedeliveryConsumerTest.java	2009-06-12 09:01:17 UTC (rev 7315)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/RedeliveryConsumerTest.java	2009-06-12 09:22:20 UTC (rev 7316)
@@ -33,6 +33,7 @@
 import org.jboss.messaging.core.config.impl.ConfigurationImpl;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.logging.Logger;
+import org.jboss.messaging.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.jboss.messaging.core.remoting.impl.invm.InVMConnectorFactory;
 import org.jboss.messaging.core.server.Messaging;
 import org.jboss.messaging.core.server.MessagingServer;
@@ -246,10 +247,12 @@
    private void setUp(final boolean persistDeliveryCountBeforeDelivery) throws Exception, MessagingException
    {
       Configuration config = createConfigForJournal();
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
       config.setJournalFileSize(10 * 1024);
       config.setJournalMinFiles(2);
       config.setSecurityEnabled(false);
       config.setPersistDeliveryCountBeforeDelivery(persistDeliveryCountBeforeDelivery);
+      config.getAcceptorConfigurations().add(new TransportConfiguration(InVMAcceptorFactory.class.getCanonicalName()));
 
       server = createServer(true, config);