[jboss-cvs] JBoss Messaging SVN: r4084 - trunk/tests/src/org/jboss/messaging/tests/integration/core/remoting/impl.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Apr 21 05:02:33 EDT 2008
Author: jmesnil
Date: 2008-04-21 05:02:33 -0400 (Mon, 21 Apr 2008)
New Revision: 4084
Modified:
trunk/tests/src/org/jboss/messaging/tests/integration/core/remoting/impl/CrashClient.java
Log:
refactored CrashClient to use Location interface
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/core/remoting/impl/CrashClient.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/core/remoting/impl/CrashClient.java 2008-04-21 09:01:14 UTC (rev 4083)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/core/remoting/impl/CrashClient.java 2008-04-21 09:02:33 UTC (rev 4084)
@@ -31,15 +31,13 @@
import org.jboss.messaging.core.client.ClientConsumer;
import org.jboss.messaging.core.client.ClientProducer;
import org.jboss.messaging.core.client.ClientSession;
+import org.jboss.messaging.core.client.Location;
import org.jboss.messaging.core.client.impl.ClientConnectionFactoryImpl;
import org.jboss.messaging.core.client.impl.LocationImpl;
import org.jboss.messaging.core.config.impl.ConfigurationImpl;
import org.jboss.messaging.core.logging.Logger;
import org.jboss.messaging.core.message.impl.MessageImpl;
-import org.jboss.messaging.core.server.MessagingServer;
-import org.jboss.messaging.core.server.impl.MessagingServerImpl;
import org.jboss.messaging.jms.client.JBossTextMessage;
-import org.jboss.messaging.tests.unit.core.remoting.impl.ConfigurationHelper;
/**
@@ -74,13 +72,8 @@
int numberOfConnections = Integer.parseInt(args[0]);
- ConfigurationImpl config = ConfigurationHelper.newConfiguration(TCP,
- "localhost", ConfigurationImpl.DEFAULT_REMOTING_PORT);
-
- // FIXME there should be another way to get a meaningful Version on the
- // client side...
- MessagingServer server = new MessagingServerImpl();
- ClientConnectionFactory cf = new ClientConnectionFactoryImpl(0, new LocationImpl(TCP, "localhost", ConfigurationImpl.DEFAULT_REMOTING_PORT));
+ Location location = new LocationImpl(TCP, "localhost", ConfigurationImpl.DEFAULT_REMOTING_PORT);
+ ClientConnectionFactory cf = new ClientConnectionFactoryImpl(0, location);
ClientConnection conn = cf.createConnection();
ClientSession session = conn.createClientSession(false, true, true, -1, false, false);
ClientProducer producer = session.createProducer(QUEUE);
More information about the jboss-cvs-commits
mailing list