activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1157715 - /activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java
Date Mon, 15 Aug 2011 06:09:09 GMT
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());
     }
 



Mime
View raw message