public class PolicyEntry extends DestinationMapEntry
PolicyMap
for assigning policies to a
specific destination or a hierarchical wildcard area of destinations.Constructor and Description |
---|
PolicyEntry() |
Modifier and Type | Method and Description |
---|---|
void |
baseConfiguration(Broker broker,
BaseDestination destination) |
void |
configure(Broker broker,
Queue queue) |
void |
configure(Broker broker,
SystemUsage memoryManager,
DurableTopicSubscription sub) |
void |
configure(Broker broker,
SystemUsage memoryManager,
QueueBrowserSubscription sub) |
void |
configure(Broker broker,
SystemUsage memoryManager,
QueueSubscription sub) |
void |
configure(Broker broker,
SystemUsage memoryManager,
TopicSubscription subscription) |
void |
configure(Broker broker,
Topic topic) |
long |
getBlockedProducerWarningInterval() |
int |
getConsumersBeforeDispatchStarts() |
int |
getCursorMemoryHighWaterMark() |
DeadLetterStrategy |
getDeadLetterStrategy() |
DispatchPolicy |
getDispatchPolicy() |
int |
getDurableTopicPrefetch()
Get the durableTopicPrefetch
|
long |
getExpireMessagesPeriod() |
long |
getInactiveTimoutBeforeGC() |
int |
getMaxAuditDepth() |
int |
getMaxBrowsePageSize() |
int |
getMaxExpirePageSize() |
int |
getMaxPageSize() |
int |
getMaxProducersToAudit() |
int |
getMaxQueueAuditDepth() |
long |
getMemoryLimit() |
MessageEvictionStrategy |
getMessageEvictionStrategy() |
MessageGroupMapFactory |
getMessageGroupMapFactory() |
long |
getMinimumMessageSize() |
NetworkBridgeFilterFactory |
getNetworkBridgeFilterFactory() |
int |
getOptimizeMessageStoreInFlightLimit() |
PendingDurableSubscriberMessageStoragePolicy |
getPendingDurableSubscriberPolicy() |
PendingMessageLimitStrategy |
getPendingMessageLimitStrategy() |
PendingQueueMessageStoragePolicy |
getPendingQueuePolicy() |
PendingSubscriberMessageStoragePolicy |
getPendingSubscriberPolicy() |
int |
getQueueBrowserPrefetch()
Get the queueBrowserPrefetch
|
int |
getQueuePrefetch()
Get the queuePrefetch
|
SlowConsumerStrategy |
getSlowConsumerStrategy() |
int |
getStoreUsageHighWaterMark() |
SubscriptionRecoveryPolicy |
getSubscriptionRecoveryPolicy() |
int |
getTimeBeforeDispatchStarts() |
int |
getTopicPrefetch()
Get the topicPrefetch
|
boolean |
isAdvisdoryForFastProducers() |
boolean |
isAdvisoryForConsumed() |
boolean |
isAdvisoryForDelivery() |
boolean |
isAdvisoryForDiscardingMessages() |
boolean |
isAdvisoryForSlowConsumers() |
boolean |
isAdvisoryWhenFull() |
boolean |
isAllConsumersExclusiveByDefault() |
boolean |
isAlwaysRetroactive() |
boolean |
isDoOptimzeMessageStorage() |
boolean |
isEnableAudit() |
boolean |
isGcInactiveDestinations() |
boolean |
isGcWithNetworkConsumers() |
boolean |
isLazyDispatch() |
boolean |
isOptimizedDispatch() |
boolean |
isPrioritizedMessages() |
boolean |
isProducerFlowControl() |
boolean |
isReduceMemoryFootprint() |
boolean |
isSendAdvisoryIfNoConsumers() |
boolean |
isStrictOrderDispatch() |
boolean |
isUseCache() |
boolean |
isUseConsumerPriority() |
boolean |
isUsePrefetchExtension() |
void |
setAdvisdoryForFastProducers(boolean advisdoryForFastProducers) |
void |
setAdvisoryForConsumed(boolean advisoryForConsumed) |
void |
setAdvisoryForDelivery(boolean advisoryForDelivery) |
void |
setAdvisoryForDiscardingMessages(boolean advisoryForDiscardingMessages) |
void |
setAdvisoryForSlowConsumers(boolean advisoryForSlowConsumers) |
void |
setAdvisoryWhenFull(boolean advisoryWhenFull) |
void |
setAllConsumersExclusiveByDefault(boolean allConsumersExclusiveByDefault) |
void |
setAlwaysRetroactive(boolean alwaysRetroactive) |
void |
setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
Set's the interval at which warnings about producers being blocked by
resource usage will be triggered.
|
void |
setConsumersBeforeDispatchStarts(int consumersBeforeDispatchStarts) |
void |
setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark) |
void |
setDeadLetterStrategy(DeadLetterStrategy deadLetterStrategy)
Sets the policy used to determine which dead letter queue destination
should be used
|
void |
setDispatchPolicy(DispatchPolicy policy) |
void |
setDoOptimzeMessageStorage(boolean doOptimzeMessageStorage) |
void |
setDurableTopicPrefetch(int durableTopicPrefetch)
Set the durableTopicPrefetch
|
void |
setEnableAudit(boolean enableAudit) |
void |
setExpireMessagesPeriod(long expireMessagesPeriod) |
void |
setGcInactiveDestinations(boolean gcInactiveDestinations) |
void |
setGcWithNetworkConsumers(boolean gcWithNetworkConsumers) |
void |
setInactiveTimoutBeforeGC(long inactiveTimoutBeforeGC) |
void |
setLazyDispatch(boolean lazyDispatch) |
void |
setMaxAuditDepth(int maxAuditDepth) |
void |
setMaxBrowsePageSize(int maxPageSize) |
void |
setMaxExpirePageSize(int maxExpirePageSize) |
void |
setMaxPageSize(int maxPageSize) |
void |
setMaxProducersToAudit(int maxProducersToAudit) |
void |
setMaxQueueAuditDepth(int maxQueueAuditDepth) |
void |
setMemoryLimit(long memoryLimit)
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
|
void |
setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy)
Sets the eviction strategy used to decide which message to evict when the
slow consumer needs to discard messages
|
void |
setMessageGroupMapFactory(MessageGroupMapFactory messageGroupMapFactory)
Sets the factory used to create new instances of {MessageGroupMap} used
to implement the Message Groups
functionality.
|
void |
setMinimumMessageSize(long minimumMessageSize) |
void |
setNetworkBridgeFilterFactory(NetworkBridgeFilterFactory networkBridgeFilterFactory) |
void |
setOptimizedDispatch(boolean optimizedDispatch) |
void |
setOptimizeMessageStoreInFlightLimit(int optimizeMessageStoreInFlightLimit) |
void |
setPendingDurableSubscriberPolicy(PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy) |
void |
setPendingMessageLimitStrategy(PendingMessageLimitStrategy pendingMessageLimitStrategy)
Sets the strategy to calculate the maximum number of messages that are
allowed to be pending on consumers (in addition to their prefetch sizes).
|
void |
setPendingQueuePolicy(PendingQueueMessageStoragePolicy pendingQueuePolicy) |
void |
setPendingSubscriberPolicy(PendingSubscriberMessageStoragePolicy pendingSubscriberPolicy) |
void |
setPrioritizedMessages(boolean prioritizedMessages) |
void |
setProducerFlowControl(boolean producerFlowControl) |
void |
setQueueBrowserPrefetch(int queueBrowserPrefetch)
Set the queueBrowserPrefetch
|
void |
setQueuePrefetch(int queuePrefetch)
Set the queuePrefetch
|
void |
setReduceMemoryFootprint(boolean reduceMemoryFootprint) |
void |
setSendAdvisoryIfNoConsumers(boolean sendAdvisoryIfNoConsumers)
Sends an advisory message if a non-persistent message is sent and there
are no active consumers
|
void |
setSlowConsumerStrategy(SlowConsumerStrategy slowConsumerStrategy) |
void |
setStoreUsageHighWaterMark(int storeUsageHighWaterMark) |
void |
setStrictOrderDispatch(boolean strictOrderDispatch) |
void |
setSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy subscriptionRecoveryPolicy) |
void |
setTimeBeforeDispatchStarts(int timeBeforeDispatchStarts) |
void |
setTopicPrefetch(int topicPrefetch)
Set the topicPrefetch
|
void |
setUseCache(boolean useCache) |
void |
setUseConsumerPriority(boolean useConsumerPriority) |
void |
setUsePrefetchExtension(boolean usePrefetchExtension) |
afterPropertiesSet, compareTo, getDestination, getValue, setDestination, setQueue, setTempQueue, setTempTopic, setTopic
public PolicyEntry()
public void baseConfiguration(Broker broker, BaseDestination destination)
public void configure(Broker broker, SystemUsage memoryManager, TopicSubscription subscription)
public void configure(Broker broker, SystemUsage memoryManager, DurableTopicSubscription sub)
public void configure(Broker broker, SystemUsage memoryManager, QueueBrowserSubscription sub)
public void configure(Broker broker, SystemUsage memoryManager, QueueSubscription sub)
public DispatchPolicy getDispatchPolicy()
public void setDispatchPolicy(DispatchPolicy policy)
public SubscriptionRecoveryPolicy getSubscriptionRecoveryPolicy()
public void setSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy subscriptionRecoveryPolicy)
public boolean isSendAdvisoryIfNoConsumers()
public void setSendAdvisoryIfNoConsumers(boolean sendAdvisoryIfNoConsumers)
public DeadLetterStrategy getDeadLetterStrategy()
public void setDeadLetterStrategy(DeadLetterStrategy deadLetterStrategy)
public PendingMessageLimitStrategy getPendingMessageLimitStrategy()
public void setPendingMessageLimitStrategy(PendingMessageLimitStrategy pendingMessageLimitStrategy)
public MessageEvictionStrategy getMessageEvictionStrategy()
public void setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy)
public long getMemoryLimit()
public void setMemoryLimit(long memoryLimit)
public MessageGroupMapFactory getMessageGroupMapFactory()
public void setMessageGroupMapFactory(MessageGroupMapFactory messageGroupMapFactory)
public PendingDurableSubscriberMessageStoragePolicy getPendingDurableSubscriberPolicy()
public void setPendingDurableSubscriberPolicy(PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy)
pendingDurableSubscriberPolicy
- the pendingDurableSubscriberPolicy
to setpublic PendingQueueMessageStoragePolicy getPendingQueuePolicy()
public void setPendingQueuePolicy(PendingQueueMessageStoragePolicy pendingQueuePolicy)
pendingQueuePolicy
- the pendingQueuePolicy to setpublic PendingSubscriberMessageStoragePolicy getPendingSubscriberPolicy()
public void setPendingSubscriberPolicy(PendingSubscriberMessageStoragePolicy pendingSubscriberPolicy)
pendingSubscriberPolicy
- the pendingSubscriberPolicy to setpublic boolean isProducerFlowControl()
public void setProducerFlowControl(boolean producerFlowControl)
producerFlowControl
- public boolean isAlwaysRetroactive()
public void setAlwaysRetroactive(boolean alwaysRetroactive)
alwaysRetroactive
- public void setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
blockedProducerWarningInterval
- the interval at which warning about
blocked producers will be triggered.public long getBlockedProducerWarningInterval()
public int getMaxProducersToAudit()
public void setMaxProducersToAudit(int maxProducersToAudit)
maxProducersToAudit
- the maxProducersToAudit to setpublic int getMaxAuditDepth()
public void setMaxAuditDepth(int maxAuditDepth)
maxAuditDepth
- the maxAuditDepth to setpublic boolean isEnableAudit()
public void setEnableAudit(boolean enableAudit)
enableAudit
- the enableAudit to setpublic int getMaxQueueAuditDepth()
public void setMaxQueueAuditDepth(int maxQueueAuditDepth)
public boolean isOptimizedDispatch()
public void setOptimizedDispatch(boolean optimizedDispatch)
public int getMaxPageSize()
public void setMaxPageSize(int maxPageSize)
public int getMaxBrowsePageSize()
public void setMaxBrowsePageSize(int maxPageSize)
public boolean isUseCache()
public void setUseCache(boolean useCache)
public long getMinimumMessageSize()
public void setMinimumMessageSize(long minimumMessageSize)
public boolean isUseConsumerPriority()
public void setUseConsumerPriority(boolean useConsumerPriority)
public boolean isStrictOrderDispatch()
public void setStrictOrderDispatch(boolean strictOrderDispatch)
public boolean isLazyDispatch()
public void setLazyDispatch(boolean lazyDispatch)
public int getTimeBeforeDispatchStarts()
public void setTimeBeforeDispatchStarts(int timeBeforeDispatchStarts)
public int getConsumersBeforeDispatchStarts()
public void setConsumersBeforeDispatchStarts(int consumersBeforeDispatchStarts)
public boolean isAdvisoryForSlowConsumers()
public void setAdvisoryForSlowConsumers(boolean advisoryForSlowConsumers)
advisoryForSlowConsumers
- the advisoryForSlowConsumers to setpublic boolean isAdvisoryForDiscardingMessages()
public void setAdvisoryForDiscardingMessages(boolean advisoryForDiscardingMessages)
advisoryForDiscardingMessages
- the advisoryForDiscardingMessages to setpublic boolean isAdvisoryWhenFull()
public void setAdvisoryWhenFull(boolean advisoryWhenFull)
advisoryWhenFull
- the advisoryWhenFull to setpublic boolean isAdvisoryForDelivery()
public void setAdvisoryForDelivery(boolean advisoryForDelivery)
advisoryForDelivery
- the advisoryForDelivery to setpublic boolean isAdvisoryForConsumed()
public void setAdvisoryForConsumed(boolean advisoryForConsumed)
advisoryForConsumed
- the advisoryForConsumed to setpublic boolean isAdvisdoryForFastProducers()
public void setAdvisdoryForFastProducers(boolean advisdoryForFastProducers)
advisdoryForFastProducers
- the advisdoryForFastProducers to setpublic void setMaxExpirePageSize(int maxExpirePageSize)
public int getMaxExpirePageSize()
public void setExpireMessagesPeriod(long expireMessagesPeriod)
public long getExpireMessagesPeriod()
public int getQueuePrefetch()
public void setQueuePrefetch(int queuePrefetch)
queuePrefetch
- the queuePrefetch to setpublic int getQueueBrowserPrefetch()
public void setQueueBrowserPrefetch(int queueBrowserPrefetch)
queueBrowserPrefetch
- the queueBrowserPrefetch to setpublic int getTopicPrefetch()
public void setTopicPrefetch(int topicPrefetch)
topicPrefetch
- the topicPrefetch to setpublic int getDurableTopicPrefetch()
public void setDurableTopicPrefetch(int durableTopicPrefetch)
durableTopicPrefetch
- the durableTopicPrefetch to setpublic boolean isUsePrefetchExtension()
public void setUsePrefetchExtension(boolean usePrefetchExtension)
public int getCursorMemoryHighWaterMark()
public void setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark)
public void setStoreUsageHighWaterMark(int storeUsageHighWaterMark)
public int getStoreUsageHighWaterMark()
public void setSlowConsumerStrategy(SlowConsumerStrategy slowConsumerStrategy)
public SlowConsumerStrategy getSlowConsumerStrategy()
public boolean isPrioritizedMessages()
public void setPrioritizedMessages(boolean prioritizedMessages)
public void setAllConsumersExclusiveByDefault(boolean allConsumersExclusiveByDefault)
public boolean isAllConsumersExclusiveByDefault()
public boolean isGcInactiveDestinations()
public void setGcInactiveDestinations(boolean gcInactiveDestinations)
public long getInactiveTimoutBeforeGC()
public void setInactiveTimoutBeforeGC(long inactiveTimoutBeforeGC)
public void setGcWithNetworkConsumers(boolean gcWithNetworkConsumers)
public boolean isGcWithNetworkConsumers()
public boolean isReduceMemoryFootprint()
public void setReduceMemoryFootprint(boolean reduceMemoryFootprint)
public void setNetworkBridgeFilterFactory(NetworkBridgeFilterFactory networkBridgeFilterFactory)
public NetworkBridgeFilterFactory getNetworkBridgeFilterFactory()
public boolean isDoOptimzeMessageStorage()
public void setDoOptimzeMessageStorage(boolean doOptimzeMessageStorage)
public int getOptimizeMessageStoreInFlightLimit()
public void setOptimizeMessageStoreInFlightLimit(int optimizeMessageStoreInFlightLimit)
Copyright © 2005–2016. All rights reserved.