Package org.apache.activemq.artemis.core.server.impl
package org.apache.activemq.artemis.core.server.impl
-
ClassDescriptionI need to store protocol specific data on the references.An activation controls the lifecycle of the server and any components specific to the Activation itself.The ActiveMQ Artemis server implementationThis implementation looks for any available node, once tried with no success it is marked as tried and the next available is used.This implementation looks for any available node, once tried with no success it is marked as tried and the next available is used.Instead of loading into its own post office this will use its parent server (the active server) and load into that.BucketMessageGroups, stores values against a bucket, where the bucket used is based on the provided key objects hash.This is an abstract ActivateCallback that will cleanup itself when the broker is shutodwnConnectorsService will pool some resource for updates, e.g.Implementation of MessageGroups that simply uses a NoOpMap, and in essence disables message grouping for queues that use it.A DivertImpl simply diverts a message to a different forwardAddressThis 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.NodeManager used to run multiple servers in the same VM.A queue that will discard messages if a newer message with the same
Message.HDR_LAST_VALUE_NAMEproperty value.Implementation of a MessageReferenceIt looks for a server in the cluster with a specific NodeIDLooks for a server in the cluster with a specific backupGroupNameLooks for a server in the cluster with a specific scaleDownGroupNameQueueConsumers<T extends PriorityAware>QueueConsumersImpl<T extends PriorityAware>This class's purpose is to hold the consumers.Implementation of a QueueQueueImpl.ConsumerHolder<T extends Consumer>This activation can be used by a primary while trying to fail-back iefailback == trueor by a natural-born backup iefailback == false.This is going to beReplicationPrimaryActivation.run()just by natural born primary, at the first start.Handles scheduling deliveries to a queue at the correct time.Concrete implementation of a ClientConsumer.Server side Session implementationImplementation of MessageGroups that simply uses a HashMap, this is the existing and default behaviour of message groups in artemis.