Package org.apache.activemq.transport.vm
Class VMTransportFactory
- java.lang.Object
-
- org.apache.activemq.transport.TransportFactory
-
- org.apache.activemq.transport.vm.VMTransportFactory
-
public class VMTransportFactory extends TransportFactory
-
-
Field Summary
Fields Modifier and Type Field Description static ConcurrentMap<String,BrokerService>BROKERSstatic ConcurrentMap<String,TransportConnector>CONNECTORSstatic ConcurrentMap<String,VMTransportServer>SERVERS
-
Constructor Summary
Constructors Constructor Description VMTransportFactory()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description TransportServerdoBind(URI location)TransportdoCompositeConnect(URI location)TransportdoConnect(URI location)BrokerFactoryHandlergetBrokerFactoryHandler()voidsetBrokerFactoryHandler(BrokerFactoryHandler brokerFactoryHandler)static voidstopped(String host)static voidstopped(VMTransportServer server)-
Methods inherited from class org.apache.activemq.transport.TransportFactory
bind, compositeConfigure, compositeConnect, compositeConnect, configure, connect, connect, createTransport, createWireFormat, createWireFormatFactory, doCompositeConnect, doConnect, findTransportFactory, getDefaultWireFormatType, getOption, registerTransportFactory, serverConfigure
-
-
-
-
Field Detail
-
BROKERS
public static final ConcurrentMap<String,BrokerService> BROKERS
-
CONNECTORS
public static final ConcurrentMap<String,TransportConnector> CONNECTORS
-
SERVERS
public static final ConcurrentMap<String,VMTransportServer> SERVERS
-
-
Method Detail
-
doConnect
public Transport doConnect(URI location) throws Exception
- Overrides:
doConnectin classTransportFactory- Throws:
Exception
-
doCompositeConnect
public Transport doCompositeConnect(URI location) throws Exception
- Overrides:
doCompositeConnectin classTransportFactory- Throws:
Exception
-
doBind
public TransportServer doBind(URI location) throws IOException
- Specified by:
doBindin classTransportFactory- Throws:
IOException
-
stopped
public static void stopped(VMTransportServer server)
-
stopped
public static void stopped(String host)
-
getBrokerFactoryHandler
public BrokerFactoryHandler getBrokerFactoryHandler()
-
setBrokerFactoryHandler
public void setBrokerFactoryHandler(BrokerFactoryHandler brokerFactoryHandler)
-
-