Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added better proxy connector cleanup code. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@376047 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-02-08 20:23:08 +00:00
parent 7e672d4150
commit a7ac415557
1 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
activemq-core/src/main/java/org/apache/activemq/proxy/ProxyConnector.java
View File

@ -19,16 +19,21 @@ package org.apache.activemq.proxy;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Iterator;
import org.apache.activemq.Service;
import org.apache.activemq.transport.CompositeTransport;
import org.apache.activemq.transport.Transport;
import org.apache.activemq.transport.TransportAcceptListener;
import org.apache.activemq.transport.TransportFactory;
import org.apache.activemq.transport.TransportFilter;
import org.apache.activemq.transport.TransportServer;
import org.apache.activemq.util.ServiceStopper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
/**
* @org.xbean.XBean
*
@ -42,6 +47,8 @@ public class ProxyConnector implements Service {
private URI remote;
private URI localUri;
CopyOnWriteArrayList connections = new CopyOnWriteArrayList();
public void start() throws Exception {
this.getServer().setAcceptListener(new TransportAcceptListener() {
@ -49,6 +56,7 @@ public class ProxyConnector implements Service {
try {
Transport remoteTransport = createRemoteTransport();
ProxyConnection connection = new ProxyConnection(localTransport, remoteTransport);
connections.add(connection);
connection.start();
}
catch (Exception e) {
@ -65,9 +73,15 @@ public class ProxyConnector implements Service {
}
public void stop() throws Exception {
ServiceStopper ss = new ServiceStopper();
if( this.server!=null ) {
this.server.stop();
ss.stop(this.server);
}
for (Iterator iter = connections.iterator(); iter.hasNext();) {
System.out.println("Connector stopped: Stopping proxy.");
ss.stop((Service) iter.next());
}
ss.throwFirstException();
}
// Properties
@ -121,6 +135,15 @@ public class ProxyConnector implements Service {
if( ct !=null && localUri!=null ) {
ct.add(new URI[]{localUri});
}
// Add a transport filter so that can track the transport life cycle
transport = new TransportFilter(transport) {
public void stop() throws Exception {
System.out.println("Stopping proxy.");
super.stop();
connections.remove(this);
}
};
return transport;
}