Interface | Description |
---|---|
JournalLoader | |
MessageGroups<C> | |
QueueConsumers<T extends PriorityAware> |
Class | Description |
---|---|
Activation |
An activation controls the lifecycle of the server and any components specific to the Activation itself.
|
ActiveMQServerImpl |
The ActiveMQ Artemis server implementation
|
AddressInfo | |
AnyLiveNodeLocatorForReplication |
This implementation looks for any available live node, once tried with no success it is marked as
tried and the next available is used.
|
AnyLiveNodeLocatorForScaleDown |
This implementation looks for any available live node, once tried with no success it is marked as
tried and the next available is used.
|
BackupRecoveryJournalLoader | |
BucketMessageGroups<C> |
BucketMessageGroups, stores values against a bucket, where the bucket used is based on the provided key objects hash.
|
ColocatedActivation | |
ConnectorsService |
ConnectorsService will pool some resource for updates, e.g.
|
DisabledMessageGroups<C> |
Implementation of MessageGroups that simply uses a NoOpMap, and in essence disables message grouping for queues that use it.
|
DivertImpl |
A DivertImpl simply diverts a message to a different forwardAddress
|
FileLockNodeManager | |
GroupFirstMessageReference |
This MessageReference should only be created the first time a group is assigned to a consumer,
it allows us to make a copy of the message to add the property safely as a delivery semantic,
without affecting the underlying message.
|
InVMNodeManager |
NodeManager used to run multiple servers in the same VM.
|
LastValueQueue |
A queue that will discard messages if a newer message with the same
Message.HDR_LAST_VALUE_NAME property value. |
LegacyLDAPSecuritySettingPlugin | |
LiveActivation | |
LiveOnlyActivation | |
MessageReferenceImpl |
Implementation of a MessageReference
|
NamedLiveNodeLocatorForReplication |
NamedLiveNodeLocatorForReplication looks for a live server in the cluster with a specific backupGroupName
|
NamedLiveNodeLocatorForScaleDown |
NamedLiveNodeLocatorForScaleDown looks for a live server in the cluster with a specific scaleDownGroupName
|
NamedNodeIdNodeLocator | |
PostOfficeJournalLoader | |
QueueConsumersImpl<T extends PriorityAware> |
This class's purpose is to hold the consumers.
|
QueueFactoryImpl |
A QueueFactoryImpl
|
QueueImpl |
Implementation of a Queue
|
QueueImpl.ConsumerHolder<T extends Consumer> | |
QueueManagerImpl | |
QueuePendingMessageMetrics | |
RefsOperation | |
RoutingContextImpl | |
ScaleDownHandler | |
ScaleDownHandler.OrderQueueByNumberOfReferencesComparator | |
ScheduledDeliveryHandlerImpl |
Handles scheduling deliveries to a queue at the correct time.
|
ServerConnectVoteHandler | |
ServerConsumerImpl |
Concrete implementation of a ClientConsumer.
|
ServerInfo | |
ServerProducerImpl | |
ServerSessionImpl |
Server side Session implementation
|
ServerSessionImpl.TempQueueCleanerUpper | |
ServiceRegistryImpl | |
SharedNothingBackupActivation | |
SharedNothingLiveActivation | |
SharedStoreBackupActivation | |
SharedStoreLiveActivation | |
SimpleMessageGroups<C> |
Implementation of MessageGroups that simply uses a HashMap, this is the existing and default behaviour of message groups in artemis.
|
TransientQueueManagerImpl |
Enum | Description |
---|---|
AckReason | |
InVMNodeManager.State |
Copyright © 2019 JBoss by Red Hat. All rights reserved.