Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.ft |
Helper classes for implementing fault tolerance
|
org.apache.activemq.broker.jmx |
JMX MBeans for the broker and its core connectors.
|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.network |
Support for federated networks of brokers.
|
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
org.apache.activemq.state |
Modifier and Type | Method and Description |
---|---|
ConnectionInfo |
ActiveMQConnection.getConnectionInfo() |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<ConnectionId,ConnectionInfo> |
AdvisoryBroker.connections |
Modifier and Type | Method and Description |
---|---|
Map<ConnectionId,ConnectionInfo> |
AdvisoryBroker.getAdvisoryConnections() |
Modifier and Type | Method and Description |
---|---|
void |
AdvisoryBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
AdvisoryBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
Modifier and Type | Method and Description |
---|---|
void |
MutableBrokerFilter.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
EmptyBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
Broker.addConnection(ConnectionContext context,
ConnectionInfo info)
A client is establishing a connection with the broker.
|
void |
ErrorBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
BrokerBroadcaster.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
BrokerFilter.addConnection(ConnectionContext context,
ConnectionInfo info) |
Response |
TransportConnection.processAddConnection(ConnectionInfo info) |
void |
MutableBrokerFilter.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
EmptyBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
Broker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error)
A client is disconnecting from the broker.
|
void |
ErrorBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
BrokerBroadcaster.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
TransactionBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
BrokerFilter.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
Constructor and Description |
---|
ConnectionContext(ConnectionInfo info) |
TransportConnectionState(ConnectionInfo info,
TransportConnection transportConnection) |
Modifier and Type | Method and Description |
---|---|
void |
MasterBroker.addConnection(ConnectionContext context,
ConnectionInfo info)
A client is establishing a connection with the broker.
|
void |
MasterBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error)
A client is disconnecting from the broker.
|
Modifier and Type | Method and Description |
---|---|
Response |
ManagedTransportConnection.processAddConnection(ConnectionInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
RegionBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
RegionBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
Modifier and Type | Method and Description |
---|---|
void |
UDPTraceBrokerPlugin.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
LoggingBrokerPlugin.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
UDPTraceBrokerPlugin.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
LoggingBrokerPlugin.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
Modifier and Type | Method and Description |
---|---|
ConnectionInfo |
ConnectionInfo.copy() |
Constructor and Description |
---|
SessionInfo(ConnectionInfo connectionInfo,
long sessionId) |
Modifier and Type | Field and Description |
---|---|
protected ConnectionInfo |
DemandForwardingBridgeSupport.localConnectionInfo |
protected ConnectionInfo |
DemandForwardingBridgeSupport.remoteConnectionInfo |
Modifier and Type | Method and Description |
---|---|
void |
JaasAuthenticationBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
SimpleAuthenticationBroker.addConnection(ConnectionContext context,
ConnectionInfo info) |
void |
JaasDualAuthenticationBroker.addConnection(ConnectionContext context,
ConnectionInfo info)
Overridden to allow for authentication using different Jaas
configurations depending on if the connection is SSL or not.
|
void |
JaasCertificateAuthenticationBroker.addConnection(ConnectionContext context,
ConnectionInfo info)
Overridden to allow for authentication based on client certificates.
|
void |
JaasAuthenticationBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
SimpleAuthenticationBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error) |
void |
JaasDualAuthenticationBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error)
Overriding removeConnection to make sure the security context is cleaned.
|
void |
JaasCertificateAuthenticationBroker.removeConnection(ConnectionContext context,
ConnectionInfo info,
Throwable error)
Overriding removeConnection to make sure the security context is cleaned.
|
Modifier and Type | Method and Description |
---|---|
ConnectionInfo |
ConnectionState.getInfo() |
Modifier and Type | Method and Description |
---|---|
Response |
ConnectionStateTracker.processAddConnection(ConnectionInfo info) |
Response |
CommandVisitor.processAddConnection(ConnectionInfo info) |
Response |
CommandVisitorAdapter.processAddConnection(ConnectionInfo info) |
void |
ConnectionState.reset(ConnectionInfo info) |
Constructor and Description |
---|
ConnectionState(ConnectionInfo info) |
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.