You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by ng...@apache.org on 2011/01/03 23:35:57 UTC
svn commit: r1054813 - in /mina/vysper/branches/s2s/server/core-inttest: ./
src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java
src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java
Author: ngn
Date: Mon Jan 3 22:35:57 2011
New Revision: 1054813
URL: http://svn.apache.org/viewvc?rev=1054813&view=rev
Log:
Rename the integration test runner
Added:
mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java
- copied, changed from r1054572, mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java
Removed:
mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java
Modified:
mina/vysper/branches/s2s/server/core-inttest/ (props changed)
Propchange: mina/vysper/branches/s2s/server/core-inttest/
------------------------------------------------------------------------------
--- svn:ignore (original)
+++ svn:ignore Mon Jan 3 22:35:57 2011
@@ -3,3 +3,4 @@ target
.classpath
.project
s2s-jabber.org.properties
+s2s-protocol7.com.properties
Copied: mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java (from r1054572, mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java)
URL: http://svn.apache.org/viewvc/mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java?p2=mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java&p1=mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java&r1=1054572&r2=1054813&rev=1054813&view=diff
==============================================================================
--- mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/S2SIntegrationTestCase.java (original)
+++ mina/vysper/branches/s2s/server/core-inttest/src/test/java/org/apache/vysper/xmpp/server/s2s/RunS2SServers.java Mon Jan 3 22:35:57 2011
@@ -19,6 +19,7 @@ import org.apache.vysper.xmpp.authorizat
import org.apache.vysper.xmpp.server.ServerRuntimeContext;
import org.apache.vysper.xmpp.server.XMPPServer;
import org.jivesoftware.smack.ConnectionConfiguration;
+import org.jivesoftware.smack.ConnectionListener;
import org.jivesoftware.smack.PacketListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
@@ -30,20 +31,22 @@ import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
-public class S2SIntegrationTestCase extends TestCase {
+public class RunS2SServers extends TestCase {
+ private static final String FILE_FILTER = "s2s-p";
+
public static Test suite() {
File testsDir = new File(".");
File[] testFiles = testsDir.listFiles(new FilenameFilter() {
public boolean accept(File arg0, String name) {
- return name.startsWith("s2s-");
+ return name.startsWith(FILE_FILTER);
}
});
TestSuite suite = new TestSuite("S2S integration tests");
for(File testFile : testFiles) {
try {
- suite.addTest(new S2SIntegrationTestCase(testFile));
+ suite.addTest(new RunS2SServers(testFile));
} catch (IOException e) {
fail(e.getMessage());
}
@@ -54,7 +57,7 @@ public class S2SIntegrationTestCase exte
private File testFile;
private Properties config = new Properties();
- public S2SIntegrationTestCase(File testFile) throws IOException {
+ public RunS2SServers(File testFile) throws IOException {
this.testFile = testFile;
config.load(new FileInputStream(testFile));
}
@@ -69,8 +72,8 @@ public class S2SIntegrationTestCase exte
String localConnect = config.getProperty("local.connect", localServer.getFullQualifiedName());
Entity localUser = EntityImpl.parseUnchecked(config.getProperty("local.user"));
String localPassword = "password";
- Entity remoteServer = EntityImpl.parseUnchecked(config.getProperty("remote.server"));
- Entity remoteUser = EntityImpl.parseUnchecked(config.getProperty("remote.user"));
+ String remoteServer = config.getProperty("remote.server");
+ String remoteUser = config.getProperty("remote.user");
String remotePassword = config.getProperty("remote.password");
String keystorePath = config.getProperty("keystore.path");
@@ -89,7 +92,8 @@ public class S2SIntegrationTestCase exte
LinkedBlockingQueue<Packet> localClientPackages = new LinkedBlockingQueue<Packet>();
LinkedBlockingQueue<Packet> remoteClientPackages = new LinkedBlockingQueue<Packet>();
- XMPPConnection localClient = connectClient(localConnect, localUser, localPassword, keystorePath, keystorePassword, localClientPackages);
+ XMPPConnection localClient = connectClient(localConnect, localUser.getFullQualifiedName(), localPassword, keystorePath, keystorePassword, localClientPackages);
+// XMPPConnection localClient = null;
System.out.println();
System.out.println();
@@ -97,7 +101,8 @@ public class S2SIntegrationTestCase exte
System.out.println();
System.out.println();
- XMPPConnection remoteClient = connectClient(remoteServer.getDomain(), remoteUser, remotePassword, keystorePath, keystorePassword, remoteClientPackages);
+// XMPPConnection remoteClient = connectClient(remoteServer, remoteUser, remotePassword, keystorePath, keystorePassword, remoteClientPackages);
+ XMPPConnection remoteClient = null;
Thread.sleep(3000);
@@ -108,38 +113,38 @@ public class S2SIntegrationTestCase exte
System.out.println();
remoteClientPackages.clear();
- Message msg = new Message(remoteUser.getFullQualifiedName());
+ Message msg = new Message(remoteUser);
msg.setBody("Hello world");
localClient.sendPacket(msg);
- Packet packet = remoteClientPackages.poll(15000, TimeUnit.MILLISECONDS);
- if(packet != null && packet instanceof Message) {
- System.out.println("!!!!!!" + ((Message)packet).getBody());
- } else {
- fail("Message not received by remote client");
- }
-
- Thread.sleep(3000);
-
- System.out.println();
- System.out.println();
- System.out.println("Sending message from remote to local");
- System.out.println();
- System.out.println();
-
- localClientPackages.clear();
- msg = new Message(localUser.getFullQualifiedName());
- msg.setBody("Hello world");
-
- remoteClient.sendPacket(msg);
-
- packet = localClientPackages.poll(15000, TimeUnit.MILLISECONDS);
- if(packet != null && packet instanceof Message) {
- System.out.println("!!!!!!" + ((Message)packet).getBody());
- } else {
- fail("Message not received by local client");
- }
+// Packet packet = remoteClientPackages.poll(15000, TimeUnit.MILLISECONDS);
+// if(packet != null && packet instanceof Message) {
+// System.out.println("!!!!!!" + ((Message)packet).getBody());
+// } else {
+// fail("Message not received by remote client");
+// }
+//
+// Thread.sleep(3000);
+//
+// System.out.println();
+// System.out.println();
+// System.out.println("Sending message from remote to local");
+// System.out.println();
+// System.out.println();
+//
+// localClientPackages.clear();
+// msg = new Message(localUser.getFullQualifiedName());
+// msg.setBody("Hello world");
+//
+// remoteClient.sendPacket(msg);
+//
+// packet = localClientPackages.poll(15000, TimeUnit.MILLISECONDS);
+// if(packet != null && packet instanceof Message) {
+// System.out.println("!!!!!!" + ((Message)packet).getBody());
+// } else {
+// fail("Message not received by local client");
+// }
Thread.sleep(15000);
System.out.println();
@@ -156,16 +161,17 @@ public class S2SIntegrationTestCase exte
server.stop();
}
- private XMPPConnection connectClient(String host, Entity user, String password, String keystorePath, String keystorePassword, final LinkedBlockingQueue<Packet> packageQueue)
+ private XMPPConnection connectClient(String host, String user, String password, String keystorePath, String keystorePassword, final LinkedBlockingQueue<Packet> packageQueue)
throws XMPPException {
- ConnectionConfiguration connectionConfiguration = new ConnectionConfiguration(host, 5222);
+// ConnectionConfiguration connectionConfiguration = new ConnectionConfiguration(host, 5222);
+ ConnectionConfiguration connectionConfiguration = new ConnectionConfiguration(host, 5222, "protocol7.com");
connectionConfiguration.setKeystorePath(keystorePath);
connectionConfiguration.setTruststorePath(keystorePath);
connectionConfiguration.setTruststorePassword(keystorePassword);
XMPPConnection client = new XMPPConnection(connectionConfiguration);
-
+
client.connect();
- client.login(user.getNode(), password);
+ client.login(user, password);
client.addPacketListener(new PacketListener() {
public void processPacket(Packet packet) {
System.out.println("# " + packet);