vanitasvitae/Smack
1
0
Fork 0
mirror of https://github.com/vanitasvitae/Smack.git synced 2024-11-23 04:22:05 +01:00
Code Issues Releases Wiki Activity

Initial version.

Browse source 
git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/trunk@2433 b35dd754-fafc-0310-a699-88a17e54d16e
This commit is contained in:
Gaston Dombiak 2004-12-23 18:49:53 +00:00 committed by gaston
parent e50259f0ee
commit 9525df0c87
1 changed files with 58 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
test/org/jivesoftware/smack/FloodTest.java Normal file
View file

@ -0,0 +1,58 @@
/**
* $RCSfile$
* $Revision$
* $Date$
*
* Copyright (C) 2004 Jive Software. All rights reserved.
*
* This software is published under the terms of the GNU Public License (GPL),
* a copy of which is included in this distribution.
*/
package org.jivesoftware.smack;
import org.jivesoftware.smack.test.SmackTestCase;
/**
* Simple test to measure server performance.
*
* @author Gaston Dombiak
*/
public class FloodTest extends SmackTestCase {
public FloodTest(String arg0) {
super(arg0);
}
public void testMessageFlood() {
try {
Chat chat11 = getConnection(0).createChat(getBareJID(1));
Chat chat12 = new Chat(getConnection(1), getBareJID(0), chat11.getThreadID());
Chat chat21 = getConnection(0).createChat(getBareJID(2));
Chat chat22 = new Chat(getConnection(2), getBareJID(0), chat21.getThreadID());
Chat chat31 = getConnection(0).createChat(getBareJID(3));
Chat chat32 = new Chat(getConnection(3), getBareJID(0), chat31.getThreadID());
for (int i=0; i<500; i++) {
chat11.sendMessage("Hello_1" + i);
chat21.sendMessage("Hello_2" + i);
chat31.sendMessage("Hello_3" + i);
}
for (int i=0; i<500; i++) {
assertNotNull("Some message was lost (" + i + ")", chat12.nextMessage(1000));
assertNotNull("Some message was lost (" + i + ")", chat22.nextMessage(1000));
assertNotNull("Some message was lost (" + i + ")", chat32.nextMessage(1000));
}
}
catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
}
}
protected int getMaxConnections() {
return 4;
}
}