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 | |
SubscriptionRecoveryPolicy |
Abstraction to allow different recovery policies to be plugged
into the region implementations.
|
Class | Description |
---|---|
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.
|
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.
|
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. |
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-2013 The Apache Software Foundation. All Rights Reserved.