You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2011/08/15 08:09:09 UTC
svn commit: r1157715 -
/activemq/activemq-apollo/trunk/apollo-util/src/test/scala/org/apache/activemq/apollo/util/SocketProxy.java
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());
}