|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.TransportFactory
public abstract class TransportFactory
Constructor Summary | |
---|---|
TransportFactory()
|
Method Summary | |
---|---|
static TransportServer |
bind(java.lang.String brokerId,
java.net.URI location)
|
Transport |
compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport. |
static Transport |
compositeConnect(java.net.URI location)
Creates a slimmed down transport that is more efficient so that it can be used by composite transports like reliable and HA. |
static Transport |
compositeConnect(java.net.URI location,
edu.emory.mathcs.backport.java.util.concurrent.Executor ex)
Creates a slimmed down transport that is more efficient so that it can be used by composite transports like reliable and HA. |
Transport |
configure(Transport transport,
WireFormat wf,
java.util.Map options)
Fully configures and adds all need transport filters so that the transport can be used by the JMS client. |
static Transport |
connect(java.net.URI location)
Creates a normal transport. |
static Transport |
connect(java.net.URI location,
edu.emory.mathcs.backport.java.util.concurrent.Executor ex)
Creates a normal transport. |
protected Transport |
createTransport(java.net.URI location,
WireFormat wf)
Factory method to create a new transport |
protected WireFormat |
createWireFormat(java.util.Map options)
|
protected WireFormatFactory |
createWireFormatFactory(java.util.Map options)
|
abstract TransportServer |
doBind(java.lang.String brokerId,
java.net.URI location)
|
Transport |
doCompositeConnect(java.net.URI location)
|
Transport |
doCompositeConnect(java.net.URI location,
edu.emory.mathcs.backport.java.util.concurrent.Executor ex)
|
Transport |
doConnect(java.net.URI location)
|
Transport |
doConnect(java.net.URI location,
edu.emory.mathcs.backport.java.util.concurrent.Executor ex)
|
protected java.lang.String |
getDefaultWireFormatType()
|
Transport |
serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
Fully configures and adds all need transport filters so that the transport can be used by the ActiveMQ message broker. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TransportFactory()
Method Detail |
---|
public abstract TransportServer doBind(java.lang.String brokerId, java.net.URI location) throws java.io.IOException
java.io.IOException
public Transport doConnect(java.net.URI location, edu.emory.mathcs.backport.java.util.concurrent.Executor ex) throws java.lang.Exception
java.lang.Exception
public Transport doCompositeConnect(java.net.URI location, edu.emory.mathcs.backport.java.util.concurrent.Executor ex) throws java.lang.Exception
java.lang.Exception
public static Transport connect(java.net.URI location) throws java.lang.Exception
location
-
java.lang.Exception
public static Transport connect(java.net.URI location, edu.emory.mathcs.backport.java.util.concurrent.Executor ex) throws java.lang.Exception
location
- ex
-
java.lang.Exception
public static Transport compositeConnect(java.net.URI location) throws java.lang.Exception
location
-
java.lang.Exception
public static Transport compositeConnect(java.net.URI location, edu.emory.mathcs.backport.java.util.concurrent.Executor ex) throws java.lang.Exception
location
- ex
-
java.lang.Exception
public static TransportServer bind(java.lang.String brokerId, java.net.URI location) throws java.io.IOException
java.io.IOException
public Transport doConnect(java.net.URI location) throws java.lang.Exception
java.lang.Exception
public Transport doCompositeConnect(java.net.URI location) throws java.lang.Exception
java.lang.Exception
protected Transport createTransport(java.net.URI location, WireFormat wf) throws java.net.MalformedURLException, java.net.UnknownHostException, java.io.IOException
java.io.IOException
java.net.UnknownHostException
java.net.MalformedURLException
protected WireFormat createWireFormat(java.util.Map options) throws java.io.IOException
java.io.IOException
protected WireFormatFactory createWireFormatFactory(java.util.Map options) throws java.io.IOException
java.io.IOException
protected java.lang.String getDefaultWireFormatType()
public Transport configure(Transport transport, WireFormat wf, java.util.Map options) throws java.lang.Exception
transport
- wf
- options
-
java.lang.Exception
public Transport serverConfigure(Transport transport, WireFormat format, java.util.HashMap options) throws java.lang.Exception
transport
- format
- options
-
java.lang.Exception
public Transport compositeConfigure(Transport transport, WireFormat format, java.util.Map options)
transport
- format
- options
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |