svn commit: r1157715 - /activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java

[chirino]

Author: chirino
Date: Mon Aug 15 06:09:09 2011
New Revision: 1157715

URL: http://svn.apache.org/viewvc?rev=1157715&view=rev
Log:
use suspend/resume verbs to pause/unpause the connections.

Modified:
    
activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java

Modified: 
activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java
URL: 
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java?rev=1157715&r1=1157714&r2=1157715&view=diff
==============================================================================
--- 
activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java
 (original)
+++ 
activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java
 Mon Aug 15 06:09:09 2011
@@ -105,7 +105,7 @@ public class SocketProxy {
      * pause accepting new connecitons and data transfer through existing proxy
      * connections. All sockets remain open
      */
-    public void pause() {
+    public void suspend() {
         synchronized(connections) {
             LOG.info("pause, numConnectons=" + connections.size());
             acceptor.pause();
@@ -118,7 +118,7 @@ public class SocketProxy {
     /*
      * continue after pause
      */
-    public void goOn() {
+    public void resume() {
         synchronized(connections) {
             LOG.info("goOn, numConnectons=" + connections.size());
             for (Connection con : connections) {
@@ -138,7 +138,6 @@ public class SocketProxy {
 
     private URI urlFromSocket(URI uri, ServerSocket serverSocket) throws 
Exception {
         int listenPort = serverSocket.getLocalPort();
-
         return new URI(uri.getScheme(), uri.getUserInfo(), uri.getHost(), 
listenPort, uri.getPath(), uri.getQuery(), uri.getFragment());
     }