| 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(java.lang.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(java.net.URI bindAddress)
Adds a new transport connector for the given bind address
|
TransportConnector |
SslBrokerService.addSslConnector(java.lang.String bindAddress,
javax.net.ssl.KeyManager[] km,
javax.net.ssl.TrustManager[] tm,
java.security.SecureRandom random)
Adds a new transport connector for the given bind address.
|
TransportConnector |
SslBrokerService.addSslConnector(java.net.URI bindAddress,
javax.net.ssl.KeyManager[] km,
javax.net.ssl.TrustManager[] tm,
java.security.SecureRandom random)
Adds a new transport connector for the given bind address.
|
protected TransportConnector |
BrokerService.createTransportConnector(java.net.URI brokerURI) |
TransportConnector |
BrokerService.getConnectorByName(java.lang.String connectorName) |
TransportConnector |
BrokerService.getTransportConnectorByName(java.lang.String name) |
TransportConnector |
BrokerService.getTransportConnectorByScheme(java.lang.String scheme) |
protected TransportConnector |
BrokerService.registerConnectorMBean(TransportConnector connector) |
protected TransportConnector |
BrokerService.startTransportConnector(TransportConnector connector) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<TransportConnector> |
BrokerService.getTransportConnectors() |
| Modifier and Type | Method and Description |
|---|---|
TransportConnector |
BrokerService.addConnector(TransportConnector connector)
Adds a new transport connector
|
java.lang.String |
PublishedAddressPolicy.getPublishableConnectString(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.
|
protected TransportConnector |
BrokerService.startTransportConnector(TransportConnector connector) |
protected void |
BrokerService.unregisterConnectorMBean(TransportConnector connector) |
| Modifier and Type | Method and Description |
|---|---|
void |
BrokerService.setTransportConnectors(java.util.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,
javax.management.ObjectName connectorName) |
| Modifier and Type | Field and Description |
|---|---|
static java.util.concurrent.ConcurrentHashMap<java.lang.String,TransportConnector> |
VMTransportFactory.CONNECTORS |
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.