java.lang.Object
org.activemq.transport.TransportChannelFactorySupport
org.activemq.transport.tcp.TcpTransportChannelFactory
org.activemq.transport.tcp.SfTransportChannelFactory
- All Implemented Interfaces:
- org.activemq.transport.TransportChannelFactory
- public class SfTransportChannelFactory
- extends TcpTransportChannelFactory
A factory of TcpTransportChannelFactory instances using a SocketFactory
- Version:
- $Revision: 1.1.1.1 $
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
socketFactory
private javax.net.SocketFactory socketFactory
executor
private EDU.oswego.cs.dl.util.concurrent.Executor executor
SfTransportChannelFactory
public SfTransportChannelFactory(javax.net.SocketFactory socketFactory)
create
public org.activemq.transport.TransportChannel create(org.activemq.io.WireFormat wireFormat,
java.net.URI remoteLocation)
throws javax.jms.JMSException
- Create a Channel to a remote Node - e.g. a Broker
- Specified by:
create in interface org.activemq.transport.TransportChannelFactory- Overrides:
create in class TcpTransportChannelFactory
create
public org.activemq.transport.TransportChannel create(org.activemq.io.WireFormat wireFormat,
java.net.URI remoteLocation,
java.net.URI localLocation)
throws javax.jms.JMSException
- Create a Channel to a remote Node - e.g. a Broker
- Specified by:
create in interface org.activemq.transport.TransportChannelFactory- Overrides:
create in class TcpTransportChannelFactory
createSocket
protected java.net.Socket createSocket(java.net.URI remoteLocation)
throws java.io.IOException
createSocket
protected java.net.Socket createSocket(java.net.URI remoteLocation,
java.net.URI localLocation)
throws java.io.IOException