Package org.apache.activemq.broker.region.policy
The policies which can be associated with a particular destination or wildcard.
-
Interface Summary Interface Description DeadLetterStrategy A strategy for choosing which destination is used for dead letter queue messages.DispatchPolicy Abstraction to allow different dispatching policies to be plugged into the topic region implementations.DispatchSelector Determines if a subscription can dispatch a message referenceMessageEvictionStrategy A strategy for evicting messages from slow consumers.MessageQuery Represents some kind of query which will load initial messages from some source for a new topic subscriber.PendingDurableSubscriberMessageStoragePolicy Abstraction to allow different policies for holding messages awaiting dispatch to active clientsPendingMessageLimitStrategy A pluggable strategy to calculate the maximum number of messages that are allowed to be pending on consumers (in addition to their prefetch sizes).PendingQueueMessageStoragePolicy Abstraction to allow different policies for holding messages awaiting dispatch on a QueuePendingSubscriberMessageStoragePolicy Abstraction to allow different policies for holding messages awaiting dispatch to active clientsSlowConsumerStrategy Interface for a strategy for dealing with slow consumersSubscriptionRecoveryPolicy Abstraction to allow different recovery policies to be plugged into the region implementations. -
Class Summary Class Description AbortSlowAckConsumerStrategy Abort slow consumers when they reach the configured threshold of slowness, default is that a consumer that has not Ack'd a message for 30 seconds is slow.AbortSlowConsumerStrategy Abort slow consumers when they reach the configured threshold of slowness, default is slow for 30 secondsAbstractDeadLetterStrategy A strategy for choosing which destination is used for dead letter queue messages.ClientIdFilterDispatchPolicy ClientIdFilterDispatchPolicy dispatches messages in a topic to a given client.ConstantPendingMessageLimitStrategy This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.DiscardingDeadLetterStrategy ADeadLetterStrategy
where each destination has its own individual DLQ using the subject naming hierarchy.FilePendingDurableSubscriberMessageStoragePolicy Creates a PendIngMessageCursor for Durable subscribers *FilePendingQueueMessageStoragePolicy Creates a FilePendingMessageCursor *FilePendingSubscriberMessageStoragePolicy Creates a PendIngMessageCursor for Durable subscribers *FixedCountSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will keep a fixed count of last messages.FixedSizedSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will keep a fixed amount of memory available in RAM for message history which is evicted in time order.IndividualDeadLetterStrategy ADeadLetterStrategy
where each destination has its own individual DLQ using the subject naming hierarchy.LastImageSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will only keep the last message.MessageEvictionStrategySupport A useful base class for implementation inheritence.NoSubscriptionRecoveryPolicy This SubscriptionRecoveryPolicy disable recovery of messages.OldestMessageEvictionStrategy An eviction strategy which evicts the oldest message first (which is the default).OldestMessageWithLowestPriorityEvictionStrategy An eviction strategy which evicts the oldest message with the lowest priority first.PolicyEntry Represents an entry in aPolicyMap
for assigning policies to a specific destination or a hierarchical wildcard area of destinations.PolicyMap Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.PrefetchRatePendingMessageLimitStrategy This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.PriorityDispatchPolicy Priority dispatch policy that sends a message to every subscription that matches the message in consumer priority order.PriorityNetworkDispatchPolicy dispatch policy that ignores lower priority duplicate network consumers, used in conjunction with network bridge suppresDuplicateTopicSubscriptionsQueryBasedSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will perform a user specific query mechanism to load any messages they may have missed.RedeliveryPolicyMap Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.RetainedMessageSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will only keep the last non-zero length message with theActiveMQMessage
.RETAIN_PROPERTY.RoundRobinDispatchPolicy Simple dispatch policy that sends a message to every subscription that matches the message.SharedDeadLetterStrategy A default implementation ofDeadLetterStrategy
which uses a constant destination.SimpleDispatchPolicy Simple dispatch policy that sends a message to every subscription that matches the message.SimpleDispatchSelector Simple dispatch policy that determines if a message can be sent to a subscriptionSlowConsumerEntry StorePendingDurableSubscriberMessageStoragePolicy Creates a PendingMessageCursor that access the persistent store to retrieve messagesStorePendingQueueMessageStoragePolicy Creates a StoreQueueCursor *StrictOrderDispatchPolicy Dispatch policy that causes every subscription to see messages in the same order.TimedSubscriptionRecoveryPolicy This implementation ofSubscriptionRecoveryPolicy
will keep a timed buffer of messages around in memory and use that to recover new subscriptions.UniquePropertyMessageEvictionStrategy An eviction strategy which evicts the oldest message within messages with the same property valueVMPendingDurableSubscriberMessageStoragePolicy Creates a VMPendingMessageCursor *VMPendingQueueMessageStoragePolicy Creates a VMPendingMessageCursor *VMPendingSubscriberMessageStoragePolicy Creates a VMPendingMessageCursor *