Modifier and Type | Class and Description |
---|---|
class |
WebServerComponent |
Modifier and Type | Interface and Description |
---|---|
interface |
ExternalComponent |
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionFactoryImpl.connectionCreated(ActiveMQComponent component,
Connection connection,
ClientProtocolManager protocol) |
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryGroup
This class is used to search for members on the cluster through the opaque interface
BroadcastEndpoint . |
Modifier and Type | Method and Description |
---|---|
Map<String,ActiveMQComponent> |
FileDeploymentManager.buildService(ActiveMQSecurityManager securityManager,
MBeanServer mBeanServer) |
Modifier and Type | Method and Description |
---|---|
void |
FileConfiguration.buildService(ActiveMQSecurityManager securityManager,
MBeanServer mBeanServer,
Map<String,Deployable> deployables,
Map<String,ActiveMQComponent> components) |
Modifier and Type | Method and Description |
---|---|
void |
Deployable.buildService(ActiveMQSecurityManager securityManager,
MBeanServer mBeanServer,
Map<String,Deployable> deployables,
Map<String,ActiveMQComponent> components) |
Modifier and Type | Interface and Description |
---|---|
interface |
Journal
Most methods on the journal provide a blocking version where you select the sync mode and a non
blocking mode where you pass a completion callback as a parameter.
|
interface |
TestableJournal |
Modifier and Type | Class and Description |
---|---|
class |
FileWrapperJournal
Journal used at a replicating backup server during the synchronization of data with the 'live'
server.
|
class |
JournalImpl
A circular log implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PagingManager
+--------------+ 1 +----------------+ N +--------------+ N +--------+ 1 +-------------------+
|
PostOffice |-------> |PagingManager |-------> |PagingStore | ------> | Page | ------> | SequentialFile |
+--------------+ +----------------+ +--------------+ +--------+ +-------------------+
| 1 ^
| |
| |
| | 1
| N +----------+
+------------> | Address |
+----------+ |
interface |
PagingStore
The implementation will take care of details such as PageSize.
|
Modifier and Type | Class and Description |
---|---|
class |
PagingManagerImpl |
class |
PagingStoreImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
StorageManager
A StorageManager
Note about IDGEnerator
I've changed StorageManager to extend IDGenerator, because in some places
all we needed from the StorageManager was the idGeneration.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJournalStorageManager
Controls access to the journals and other storage files such as the ones used to store pages and
large messages.
|
class |
JDBCJournalStorageManager |
class |
JournalStorageManager |
Modifier and Type | Class and Description |
---|---|
class |
NullStorageManager |
Modifier and Type | Interface and Description |
---|---|
interface |
PostOffice
A PostOffice instance maintains a mapping of a String address to a Queue.
|
Modifier and Type | Class and Description |
---|---|
class |
PostOfficeImpl
This is the class that will make the routing to Queues and decide which consumer will get the messages
It's the queue component on distributing the messages * *
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAcceptor |
Modifier and Type | Class and Description |
---|---|
class |
InVMAcceptor |
Modifier and Type | Class and Description |
---|---|
class |
NettyAcceptor
A Netty TCP Acceptor that is embedding Netty.
|
Modifier and Type | Method and Description |
---|---|
void |
RemotingServiceImpl.connectionCreated(ActiveMQComponent component,
Connection connection,
ProtocolManager protocol) |
Modifier and Type | Class and Description |
---|---|
class |
ReplicatedJournal
Used by the
JournalStorageManager to replicate journal calls. |
class |
ReplicationEndpoint
Handles all the synchronization necessary for replication on the backup side (that is the
backup's side of the "remote backup" use case).
|
class |
ReplicationManager
Manages replication tasks on the live server (that is the live server side of a "remote backup"
use case).
|
Modifier and Type | Interface and Description |
---|---|
interface |
ActiveMQServer
This interface defines the internal interface of the ActiveMQ Artemis Server exposed to other components
of the server.
|
interface |
ConnectorService |
Modifier and Type | Class and Description |
---|---|
class |
MemoryManager
A memory usage watcher.
|
class |
NodeManager |
Modifier and Type | Interface and Description |
---|---|
interface |
Bridge
A Core Bridge
|
interface |
BroadcastGroup |
interface |
ClusterConnection |
Modifier and Type | Class and Description |
---|---|
class |
BackupManager |
class |
ClusterController
used for creating and managing cluster control connections for each cluster connection and the replication connection
|
class |
ClusterManager
|
Modifier and Type | Interface and Description |
---|---|
interface |
HAManager |
Modifier and Type | Class and Description |
---|---|
class |
ColocatedHAManager |
class |
StandaloneHAManager |
Modifier and Type | Class and Description |
---|---|
class |
BridgeImpl
A Core BridgeImpl
|
class |
BroadcastGroupImpl
This class will use the
BroadcastEndpoint to send periodical updates on the list for connections
used by this server. |
class |
ClusterConnectionBridge
A bridge with extra functionality only available when the server is clustered.
|
class |
ClusterConnectionImpl |
Modifier and Type | Class and Description |
---|---|
class |
QuorumManager
A QourumManager can be used to register a
Quorum to receive notifications
about changes to the cluster. |
Modifier and Type | Interface and Description |
---|---|
interface |
GroupingHandler |
Modifier and Type | Class and Description |
---|---|
class |
GroupHandlingAbstract |
class |
LocalGroupingHandler
A Local Grouping handler.
|
class |
RemoteGroupingHandler
A remote Grouping handler.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQServerImpl
The ActiveMQ Artemis server implementation
|
class |
AIOFileLockNodeManager
This is using the ActiveMQ Artemis Libaio Native to perform calls to flock on a Linux system.
|
class |
ConnectorsService
ConnectorsService will pool some resource for updates, e.g.
|
class |
FileLockNodeManager |
class |
InVMNodeManager
NodeManager used to run multiple servers in the same VM.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ManagementService |
Modifier and Type | Class and Description |
---|---|
class |
ManagementServiceImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
ReloadManager |
Modifier and Type | Class and Description |
---|---|
class |
ReloadManagerImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceManager |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManagerImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
Broker
A Broker os a set of ActiveMQComponents that create a Server, for instance core and jms.
|
Modifier and Type | Class and Description |
---|---|
class |
FileBroker |
Modifier and Type | Method and Description |
---|---|
Map<String,ActiveMQComponent> |
FileBroker.getComponents() |
ArrayList<ActiveMQComponent> |
FileBroker.getComponentsByStartOrder(Map<String,ActiveMQComponent> components) |
Modifier and Type | Method and Description |
---|---|
ArrayList<ActiveMQComponent> |
FileBroker.getComponentsByStartOrder(Map<String,ActiveMQComponent> components) |
Modifier and Type | Class and Description |
---|---|
class |
JDBCSequentialFileFactory |
Modifier and Type | Class and Description |
---|---|
class |
JDBCJournalImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
JMSBridge |
Modifier and Type | Class and Description |
---|---|
class |
JMSBridgeImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
JMSStorageManager |
Modifier and Type | Class and Description |
---|---|
class |
JMSJournalStorageManagerImpl |
Modifier and Type | Class and Description |
---|---|
class |
NullJMSStorageManagerImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
JMSServerManager
The JMS Management interface.
|
Modifier and Type | Method and Description |
---|---|
void |
FileJMSConfiguration.buildService(ActiveMQSecurityManager securityManager,
MBeanServer mBeanServer,
Map<String,Deployable> deployables,
Map<String,ActiveMQComponent> components) |
Modifier and Type | Class and Description |
---|---|
class |
JMSServerManagerImpl
A Deployer used to create and add to Bindings queues, topics and connection
factories.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ProtocolTrackerCallBack |
Modifier and Type | Method and Description |
---|---|
Map<String,ActiveMQComponent> |
OsgiBroker.getComponents() |
ArrayList<ActiveMQComponent> |
OsgiBroker.getComponentsByStartOrder(Map<String,ActiveMQComponent> components) |
Modifier and Type | Method and Description |
---|---|
ArrayList<ActiveMQComponent> |
OsgiBroker.getComponentsByStartOrder(Map<String,ActiveMQComponent> components) |
Modifier and Type | Interface and Description |
---|---|
interface |
Acceptor
An Acceptor is used by the RemotingService to allow clients to connect.
|
Modifier and Type | Method and Description |
---|---|
void |
BaseConnectionLifeCycleListener.connectionCreated(ActiveMQComponent component,
Connection connection,
ProtocolClass protocol)
This method is used both by client connector creation and server connection creation through
acceptors.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.