Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.jmx |
JMX MBeans for the broker and its core connectors.
|
org.apache.activemq.transport.vm |
In-JVM based Transport implementation.
|
Modifier and Type | Field and Description |
---|---|
protected TransportConnector |
TransportConnection.connector |
Modifier and Type | Method and Description |
---|---|
TransportConnector |
BrokerService.addConnector(String bindAddress)
Adds a new transport connector for the given bind address
|
TransportConnector |
BrokerService.addConnector(TransportConnector connector)
Adds a new transport connector
|
TransportConnector |
BrokerService.addConnector(TransportServer transport)
Adds a new transport connector for the given TransportServer transport
|
TransportConnector |
BrokerService.addConnector(URI bindAddress)
Adds a new transport connector for the given bind address
|
TransportConnector |
SslBrokerService.addSslConnector(String bindAddress,
KeyManager[] km,
TrustManager[] tm,
SecureRandom random)
Adds a new transport connector for the given bind address.
|
TransportConnector |
SslBrokerService.addSslConnector(URI bindAddress,
KeyManager[] km,
TrustManager[] tm,
SecureRandom random)
Adds a new transport connector for the given bind address.
|
protected TransportConnector |
BrokerService.createTransportConnector(URI brokerURI) |
TransportConnector |
BrokerService.getConnectorByName(String connectorName) |
TransportConnector |
BrokerService.getTransportConnectorByName(String name) |
TransportConnector |
BrokerService.getTransportConnectorByScheme(String scheme) |
protected TransportConnector |
BrokerService.registerConnectorMBean(TransportConnector connector) |
TransportConnector |
BrokerService.startTransportConnector(TransportConnector connector) |
Modifier and Type | Method and Description |
---|---|
List<TransportConnector> |
BrokerService.getTransportConnectors() |
Modifier and Type | Method and Description |
---|---|
TransportConnector |
BrokerService.addConnector(TransportConnector connector)
Adds a new transport connector
|
String |
PublishedAddressPolicy.getPublishableConnectString(TransportConnector connector) |
URI |
PublishedAddressPolicy.getPublishableConnectURI(TransportConnector connector)
Using the supplied TransportConnector this method returns the String that will
be used to update clients with this connector's connect address.
|
protected TransportConnector |
BrokerService.registerConnectorMBean(TransportConnector connector) |
boolean |
BrokerService.removeConnector(TransportConnector connector)
Stops and removes a transport connector from the broker.
|
TransportConnector |
BrokerService.startTransportConnector(TransportConnector connector) |
protected void |
BrokerService.unregisterConnectorMBean(TransportConnector connector) |
Modifier and Type | Method and Description |
---|---|
void |
BrokerService.setTransportConnectors(List<TransportConnector> transportConnectors)
Sets the transport connectors which this broker will listen on for new
clients
|
Constructor and Description |
---|
TransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory taskRunnerFactory,
TaskRunnerFactory stopTaskRunnerFactory) |
Modifier and Type | Class and Description |
---|---|
class |
ManagedTransportConnector
A managed transport connector which can create multiple managed connections
as clients connect.
|
Constructor and Description |
---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
TaskRunnerFactory stopFactory,
ManagementContext context,
ObjectName connectorName) |
Modifier and Type | Field and Description |
---|---|
static ConcurrentMap<String,TransportConnector> |
VMTransportFactory.CONNECTORS |
Copyright © 2005–2020 The Apache Software Foundation. All rights reserved.