See: Description
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 reference
|
MessageEvictionStrategy |
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 clients
|
PendingMessageLimitStrategy |
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 Queue
|
PendingSubscriberMessageStoragePolicy |
Abstraction to allow different policies for holding messages awaiting
dispatch to active clients
|
SlowConsumerStrategy |
Interface for a strategy for dealing with slow consumers
|
SubscriptionRecoveryPolicy |
Abstraction to allow different recovery policies to be plugged
into the region implementations.
|
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 seconds
|
AbstractDeadLetterStrategy |
A strategy for choosing which destination is used for dead letter queue
messages.
|
ConstantPendingMessageLimitStrategy |
This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.
|
DiscardingDeadLetterStrategy |
A
DeadLetterStrategy 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 of
SubscriptionRecoveryPolicy will keep a fixed
count of last messages. |
FixedSizedSubscriptionRecoveryPolicy |
This implementation of
SubscriptionRecoveryPolicy will keep a fixed
amount of memory available in RAM for message history which is evicted in
time order. |
IndividualDeadLetterStrategy |
A
DeadLetterStrategy where each destination has its own individual
DLQ using the subject naming hierarchy. |
LastImageSubscriptionRecoveryPolicy |
This implementation of
SubscriptionRecoveryPolicy 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 a
PolicyMap 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 suppresDuplicateTopicSubscriptions
|
QueryBasedSubscriptionRecoveryPolicy |
This implementation of
SubscriptionRecoveryPolicy 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 of
SubscriptionRecoveryPolicy will only keep the
last non-zero length message with the ActiveMQMessage .RETAIN_PROPERTY. |
RoundRobinDispatchPolicy |
Simple dispatch policy that sends a message to every subscription that
matches the message.
|
SharedDeadLetterStrategy |
A default implementation of
DeadLetterStrategy 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 subscription
|
SlowConsumerEntry | |
StorePendingDurableSubscriberMessageStoragePolicy |
Creates a PendingMessageCursor that access the persistent store to retrieve
messages
|
StorePendingQueueMessageStoragePolicy |
Creates a StoreQueueCursor *
|
StrictOrderDispatchPolicy |
Dispatch policy that causes every subscription to see messages in the same
order.
|
TimedSubscriptionRecoveryPolicy |
This implementation of
SubscriptionRecoveryPolicy 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 value
|
VMPendingDurableSubscriberMessageStoragePolicy |
Creates a VMPendingMessageCursor *
|
VMPendingQueueMessageStoragePolicy |
Creates a VMPendingMessageCursor *
|
VMPendingSubscriberMessageStoragePolicy |
Creates a VMPendingMessageCursor *
|
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.