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>
BROKERS
static ConcurrentMap<String,TransportConnector>
CONNECTORS
static 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 TransportServer
doBind(URI location)
Transport
doCompositeConnect(URI location)
Transport
doConnect(URI location)
BrokerFactoryHandler
getBrokerFactoryHandler()
void
setBrokerFactoryHandler(BrokerFactoryHandler brokerFactoryHandler)
static void
stopped(String host)
static void
stopped(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:
doConnect
in classTransportFactory
- Throws:
Exception
-
doCompositeConnect
public Transport doCompositeConnect(URI location) throws Exception
- Overrides:
doCompositeConnect
in classTransportFactory
- Throws:
Exception
-
doBind
public TransportServer doBind(URI location) throws IOException
- Specified by:
doBind
in 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)
-
-