You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2008/06/04 09:25:37 UTC
svn commit: r663015 - in /mina/sandbox/jvermillard/echoclient: echoclient.sh
pom.xml src/main/java/org/apache/mina/echoclient/EchoClient.java
Author: jvermillard
Date: Wed Jun 4 00:25:37 2008
New Revision: 663015
URL: http://svn.apache.org/viewvc?rev=663015&view=rev
Log:
ng the test client for less log output and stoping session correctly
Modified:
mina/sandbox/jvermillard/echoclient/echoclient.sh
mina/sandbox/jvermillard/echoclient/pom.xml
mina/sandbox/jvermillard/echoclient/src/main/java/org/apache/mina/echoclient/EchoClient.java
Modified: mina/sandbox/jvermillard/echoclient/echoclient.sh
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/echoclient/echoclient.sh?rev=663015&r1=663014&r2=663015&view=diff
==============================================================================
--- mina/sandbox/jvermillard/echoclient/echoclient.sh (original)
+++ mina/sandbox/jvermillard/echoclient/echoclient.sh Wed Jun 4 00:25:37 2008
@@ -1,3 +1,3 @@
#!/bin/sh
-java -cp /home/vrm/.m2/repository/org/apache/mina/echoclient/1.0-SNAPSHOT/echoclient-1.0-SNAPSHOT.jar:/home/vrm/.m2/repository/org/apache/mina/mina-core/2.0.0-M2-SNAPSHOT/mina-core-2.0.0-M2-SNAPSHOT.jar:/home/vrm/.m2/repository/org/slf4j/slf4j-api/1.5.0/slf4j-api-1.5.0.jar:/home/vrm/.m2/repository/org/slf4j/slf4j-simple/1.4.3/slf4j-simple-1.4.3.jar org.apache.mina.echoclient.EchoClient $@
+/usr/bin/java -cp /home/vrm/.m2/repository/org/apache/mina/echoclient/1.0-SNAPSHOT/echoclient-1.0-SNAPSHOT.jar:/home/vrm/.m2/repository/org/apache/mina/mina-core/2.0.0-M2-SNAPSHOT/mina-core-2.0.0-M2-SNAPSHOT.jar:/home/vrm/.m2/repository/org/slf4j/slf4j-api/1.5.0/slf4j-api-1.5.0.jar:/home/vrm/.m2/repository/org/slf4j/slf4j-simple/1.5.0/slf4j-simple-1.5.0.jar org.apache.mina.echoclient.EchoClient $@&
Modified: mina/sandbox/jvermillard/echoclient/pom.xml
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/echoclient/pom.xml?rev=663015&r1=663014&r2=663015&view=diff
==============================================================================
--- mina/sandbox/jvermillard/echoclient/pom.xml (original)
+++ mina/sandbox/jvermillard/echoclient/pom.xml Wed Jun 4 00:25:37 2008
@@ -14,6 +14,11 @@
<version>2.0.0-M2-SNAPSHOT</version>
</dependency>
<dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-simple</artifactId>
+ <version>1.5.0</version>
+ </dependency>
+ <dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
Modified: mina/sandbox/jvermillard/echoclient/src/main/java/org/apache/mina/echoclient/EchoClient.java
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/echoclient/src/main/java/org/apache/mina/echoclient/EchoClient.java?rev=663015&r1=663014&r2=663015&view=diff
==============================================================================
--- mina/sandbox/jvermillard/echoclient/src/main/java/org/apache/mina/echoclient/EchoClient.java (original)
+++ mina/sandbox/jvermillard/echoclient/src/main/java/org/apache/mina/echoclient/EchoClient.java Wed Jun 4 00:25:37 2008
@@ -14,6 +14,8 @@
*/
public class EchoClient {
+ public static volatile boolean stop=false;
+
public static void main(String[] args) {
System.out.println("Echo client");
if (args.length != 4) {
@@ -46,11 +48,12 @@
ex.printStackTrace();
}
-
+ stop=true;
+ System.out.println("Closing sessions");
for (int i = 0; i < nbSession; i++) {
sessions[i].close().awaitUninterruptibly();
}
- System.out.println("Done.");
+ System.out.println("Done. Session closed");
System.out.println("Wrote "+connector.getWrittenBytes()+" bytes, over "+nbSession+" sessions.");
connector.dispose();
}
@@ -61,12 +64,12 @@
}
public void sessionOpened(IoSession session) throws Exception {
- System.out.println("Session opened");
+// System.out.println("Session opened");
}
public void sessionClosed(IoSession session) throws Exception {
- System.out.println("Session closed, tansfered " + session.getWrittenBytes() + " bytes. In " +
- (System.currentTimeMillis() - session.getCreationTime()) + " milis");
+// System.out.println("Session closed, tansfered " + session.getWrittenBytes() + " bytes. In " +
+// (System.currentTimeMillis() - session.getCreationTime()) + " milis");
}
public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
@@ -78,7 +81,8 @@
public void messageReceived(IoSession session, Object message) throws Exception {
// send back
- session.write(message);
+ if(!stop)
+ session.write(message);
}
public void messageSent(IoSession session, Object message) throws Exception {