Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » policy » [javadoc | source]
org.apache.activemq.broker.region.policy
public class: PolicyEntry [javadoc | source]
java.lang.Object
   org.apache.activemq.filter.DestinationMapEntry
      org.apache.activemq.broker.region.policy.PolicyEntry

All Implemented Interfaces:
    Comparable

Represents an entry in a PolicyMap for assigning policies to a specific destination or a hierarchical wildcard area of destinations.
Method from org.apache.activemq.broker.region.policy.PolicyEntry Summary:
baseConfiguration,   configure,   configure,   configure,   configure,   configure,   configure,   getBlockedProducerWarningInterval,   getConsumersBeforeDispatchStarts,   getCursorMemoryHighWaterMark,   getDeadLetterStrategy,   getDispatchPolicy,   getDurableTopicPrefetch,   getExpireMessagesPeriod,   getMaxAuditDepth,   getMaxBrowsePageSize,   getMaxExpirePageSize,   getMaxPageSize,   getMaxProducersToAudit,   getMaxQueueAuditDepth,   getMemoryLimit,   getMessageEvictionStrategy,   getMessageGroupMapFactory,   getMinimumMessageSize,   getPendingDurableSubscriberPolicy,   getPendingMessageLimitStrategy,   getPendingQueuePolicy,   getPendingSubscriberPolicy,   getQueueBrowserPrefetch,   getQueuePrefetch,   getSubscriptionRecoveryPolicy,   getTimeBeforeDispatchStarts,   getTopicPrefetch,   isAdvisdoryForFastProducers,   isAdvisoryForConsumed,   isAdvisoryForDelivery,   isAdvisoryForDiscardingMessages,   isAdvisoryForSlowConsumers,   isAdvisoryWhenFull,   isEnableAudit,   isLazyDispatch,   isOptimizedDispatch,   isProducerFlowControl,   isSendAdvisoryIfNoConsumers,   isStrictOrderDispatch,   isUseCache,   isUseConsumerPriority,   setAdvisdoryForFastProducers,   setAdvisoryForConsumed,   setAdvisoryForDelivery,   setAdvisoryForDiscardingMessages,   setAdvisoryForSlowConsumers,   setAdvisoryWhenFull,   setBlockedProducerWarningInterval,   setConsumersBeforeDispatchStarts,   setCursorMemoryHighWaterMark,   setDeadLetterStrategy,   setDispatchPolicy,   setDurableTopicPrefetch,   setEnableAudit,   setExpireMessagesPeriod,   setLazyDispatch,   setMaxAuditDepth,   setMaxBrowsePageSize,   setMaxExpirePageSize,   setMaxPageSize,   setMaxProducersToAudit,   setMaxQueueAuditDepth,   setMemoryLimit,   setMessageEvictionStrategy,   setMessageGroupMapFactory,   setMinimumMessageSize,   setOptimizedDispatch,   setPendingDurableSubscriberPolicy,   setPendingMessageLimitStrategy,   setPendingQueuePolicy,   setPendingSubscriberPolicy,   setProducerFlowControl,   setQueueBrowserPrefetch,   setQueuePrefetch,   setSendAdvisoryIfNoConsumers,   setStrictOrderDispatch,   setSubscriptionRecoveryPolicy,   setTimeBeforeDispatchStarts,   setTopicPrefetch,   setUseCache,   setUseConsumerPriority
Methods from org.apache.activemq.filter.DestinationMapEntry:
afterPropertiesSet,   compareTo,   getDestination,   getValue,   setDestination,   setQueue,   setTopic
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.policy.PolicyEntry Detail:
 public  void baseConfiguration(BaseDestination destination) 
 public  void configure(Topic topic) 
 public  void configure(Broker broker,
    Queue queue) 
 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 long getBlockedProducerWarningInterval() 
 public int getConsumersBeforeDispatchStarts() 
 public int getCursorMemoryHighWaterMark() 
 public DeadLetterStrategy getDeadLetterStrategy() 
 public DispatchPolicy getDispatchPolicy() 
 public int getDurableTopicPrefetch() 
    Get the durableTopicPrefetch
 public long getExpireMessagesPeriod() 
 public int getMaxAuditDepth() 
 public int getMaxBrowsePageSize() 
 public int getMaxExpirePageSize() 
 public int getMaxPageSize() 
 public int getMaxProducersToAudit() 
 public int getMaxQueueAuditDepth() 
 public long getMemoryLimit() 
 public MessageEvictionStrategy getMessageEvictionStrategy() 
 public MessageGroupMapFactory getMessageGroupMapFactory() 
 public long getMinimumMessageSize() 
 public PendingDurableSubscriberMessageStoragePolicy getPendingDurableSubscriberPolicy() 
 public PendingMessageLimitStrategy getPendingMessageLimitStrategy() 
 public PendingQueueMessageStoragePolicy getPendingQueuePolicy() 
 public PendingSubscriberMessageStoragePolicy getPendingSubscriberPolicy() 
 public int getQueueBrowserPrefetch() 
    Get the queueBrowserPrefetch
 public int getQueuePrefetch() 
    Get the queuePrefetch
 public SubscriptionRecoveryPolicy getSubscriptionRecoveryPolicy() 
 public int getTimeBeforeDispatchStarts() 
 public int getTopicPrefetch() 
    Get the topicPrefetch
 public boolean isAdvisdoryForFastProducers() 
 public boolean isAdvisoryForConsumed() 
 public boolean isAdvisoryForDelivery() 
 public boolean isAdvisoryForDiscardingMessages() 
 public boolean isAdvisoryForSlowConsumers() 
 public boolean isAdvisoryWhenFull() 
 public boolean isEnableAudit() 
 public boolean isLazyDispatch() 
 public boolean isOptimizedDispatch() 
 public boolean isProducerFlowControl() 
 public boolean isSendAdvisoryIfNoConsumers() 
 public boolean isStrictOrderDispatch() 
 public boolean isUseCache() 
 public boolean isUseConsumerPriority() 
 public  void setAdvisdoryForFastProducers(boolean advisdoryForFastProducers) 
 public  void setAdvisoryForConsumed(boolean advisoryForConsumed) 
 public  void setAdvisoryForDelivery(boolean advisoryForDelivery) 
 public  void setAdvisoryForDiscardingMessages(boolean advisoryForDiscardingMessages) 
 public  void setAdvisoryForSlowConsumers(boolean advisoryForSlowConsumers) 
 public  void setAdvisoryWhenFull(boolean advisoryWhenFull) 
 public  void setBlockedProducerWarningInterval(long blockedProducerWarningInterval) 
    Set's the interval at which warnings about producers being blocked by resource usage will be triggered. Values of 0 or less will disable warnings
 public  void setConsumersBeforeDispatchStarts(int consumersBeforeDispatchStarts) 
 public  void setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark) 
 public  void setDeadLetterStrategy(DeadLetterStrategy deadLetterStrategy) 
    Sets the policy used to determine which dead letter queue destination should be used
 public  void setDispatchPolicy(DispatchPolicy policy) 
 public  void setDurableTopicPrefetch(int durableTopicPrefetch) 
    Set the durableTopicPrefetch
 public  void setEnableAudit(boolean enableAudit) 
 public  void setExpireMessagesPeriod(long expireMessagesPeriod) 
 public  void setLazyDispatch(boolean lazyDispatch) 
 public  void setMaxAuditDepth(int maxAuditDepth) 
 public  void setMaxBrowsePageSize(int maxPageSize) 
 public  void setMaxExpirePageSize(int maxExpirePageSize) 
 public  void setMaxPageSize(int maxPageSize) 
 public  void setMaxProducersToAudit(int maxProducersToAudit) 
 public  void setMaxQueueAuditDepth(int maxQueueAuditDepth) 
 public  void setMemoryLimit(long memoryLimit) 
    When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
 public  void setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy) 
    Sets the eviction strategy used to decide which message to evict when the slow consumer needs to discard messages
 public  void setMessageGroupMapFactory(MessageGroupMapFactory messageGroupMapFactory) 
    Sets the factory used to create new instances of {MessageGroupMap} used to implement the Message Groups functionality.
 public  void setMinimumMessageSize(long minimumMessageSize) 
 public  void setOptimizedDispatch(boolean optimizedDispatch) 
 public  void setPendingDurableSubscriberPolicy(PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy) 
 public  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). Once the limit is reached, non-durable topics can then start discarding old messages. This allows us to keep dispatching messages to slow consumers while not blocking fast consumers and discarding the messages oldest first.
 public  void setPendingQueuePolicy(PendingQueueMessageStoragePolicy pendingQueuePolicy) 
 public  void setPendingSubscriberPolicy(PendingSubscriberMessageStoragePolicy pendingSubscriberPolicy) 
 public  void setProducerFlowControl(boolean producerFlowControl) 
 public  void setQueueBrowserPrefetch(int queueBrowserPrefetch) 
    Set the queueBrowserPrefetch
 public  void setQueuePrefetch(int queuePrefetch) 
    Set the queuePrefetch
 public  void setSendAdvisoryIfNoConsumers(boolean sendAdvisoryIfNoConsumers) 
    Sends an advisory message if a non-persistent message is sent and there are no active consumers
 public  void setStrictOrderDispatch(boolean strictOrderDispatch) 
 public  void setSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy subscriptionRecoveryPolicy) 
 public  void setTimeBeforeDispatchStarts(int timeBeforeDispatchStarts) 
 public  void setTopicPrefetch(int topicPrefetch) 
    Set the topicPrefetch
 public  void setUseCache(boolean useCache) 
 public  void setUseConsumerPriority(boolean useConsumerPriority)