public class org.apache.activemq.broker.region.policy.PolicyEntry extends org.apache.activemq.filter.DestinationMapEntry { private static final org.slf4j.Logger LOG; private org.apache.activemq.broker.region.policy.DispatchPolicy dispatchPolicy; private org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy subscriptionRecoveryPolicy; private boolean sendAdvisoryIfNoConsumers; private boolean sendDuplicateFromStoreToDLQ; private org.apache.activemq.broker.region.policy.DeadLetterStrategy deadLetterStrategy; private org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy pendingMessageLimitStrategy; private org.apache.activemq.broker.region.policy.MessageEvictionStrategy messageEvictionStrategy; private long memoryLimit; private java.lang.String messageGroupMapFactoryType; private org.apache.activemq.broker.region.group.MessageGroupMapFactory messageGroupMapFactory; private org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy pendingQueuePolicy; private org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy pendingDurableSubscriberPolicy; private org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy pendingSubscriberPolicy; private int maxProducersToAudit; private int maxAuditDepth; private int maxQueueAuditDepth; private boolean enableAudit; private boolean producerFlowControl; private boolean alwaysRetroactive; private long blockedProducerWarningInterval; private boolean optimizedDispatch; private int maxPageSize; private int maxBrowsePageSize; private boolean useCache; private long minimumMessageSize; private boolean useConsumerPriority; private boolean strictOrderDispatch; private boolean lazyDispatch; private int timeBeforeDispatchStarts; private int consumersBeforeDispatchStarts; private boolean advisoryForSlowConsumers; private boolean advisoryForFastProducers; private boolean advisoryForDiscardingMessages; private boolean advisoryWhenFull; private boolean advisoryForDelivery; private boolean advisoryForConsumed; private boolean includeBodyForAdvisory; private long expireMessagesPeriod; private int maxExpirePageSize; private int queuePrefetch; private int queueBrowserPrefetch; private int topicPrefetch; private int durableTopicPrefetch; private boolean usePrefetchExtension; private int cursorMemoryHighWaterMark; private int storeUsageHighWaterMark; private org.apache.activemq.broker.region.policy.SlowConsumerStrategy slowConsumerStrategy; private boolean prioritizedMessages; private boolean allConsumersExclusiveByDefault; private boolean gcInactiveDestinations; private boolean gcWithNetworkConsumers; private long inactiveTimeoutBeforeGC; private boolean reduceMemoryFootprint; private org.apache.activemq.network.NetworkBridgeFilterFactory networkBridgeFilterFactory; private boolean doOptimzeMessageStorage; private int maxDestinations; private boolean useTopicSubscriptionInflightStats; private int optimizeMessageStoreInFlightLimit; private boolean persistJMSRedelivered; private int sendFailIfNoSpace; private long sendFailIfNoSpaceAfterTimeout; public void () { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; int v, v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; specialinvoke v.()>(); v. = 1; v = ; v. = v; v. = "cached"; v. = 64; v. = 10000; v. = 10000; v. = 1; v. = 1; v. = 0; v. = 30000L; v. = 0; v. = 200; v. = 400; v. = 1; v. = 1024L; v. = 1; v. = 0; v. = 0; v. = 0; v. = 0; v. = 30000L; v. = 400; v. = 1000; v. = 500; v. = 32767; v. = 100; v. = 1; v. = 70; v. = 100; v. = 60000L; v. = 1; v = (int) -1; v. = v; v. = 1; v. = 10; v. = 0; v = (int) -1; v. = v; v. = -1L; return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.broker.region.Queue) { long v, v; org.apache.activemq.broker.Broker v; byte v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; int v, v; org.apache.activemq.broker.region.group.MessageGroupMapFactory v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v, v, v, v; org.apache.activemq.broker.region.policy.DispatchPolicy v, v; org.apache.activemq.broker.region.Queue v; org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.broker.region.Queue; virtualinvoke v.(v, v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(v, v); virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void update(org.apache.activemq.broker.region.Queue) { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.Queue v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.Queue; virtualinvoke v.(v, null); return; } public void update(org.apache.activemq.broker.region.Queue, java.util.Set) { long v, v; byte v; int v, v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Queue v; java.util.Set v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.Queue; v := @parameter: java.util.Set; virtualinvoke v.(v, v); v = specialinvoke v.("memoryLimit", v); if v == 0 goto label; v = v.; v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = specialinvoke v.("useConsumerPriority", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("strictOrderDispatch", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("optimizedDispatch", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("lazyDispatch", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("timeBeforeDispatchStarts", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("consumersBeforeDispatchStarts", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("allConsumersExclusiveByDefault", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("persistJMSRedelivered", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.broker.region.Topic) { org.apache.activemq.broker.region.policy.DispatchPolicy v, v; org.apache.activemq.broker.region.Topic v; long v, v; org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v, v, v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.region.policy.PolicyEntry v; byte v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; org.apache.activemq.usage.MemoryUsage v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.broker.region.Topic; virtualinvoke v.(v, v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); virtualinvoke v.(v); label: v = v.; v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void update(org.apache.activemq.broker.region.Topic) { org.apache.activemq.broker.region.Topic v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.Topic; virtualinvoke v.(v, null); return; } public void update(org.apache.activemq.broker.region.Topic, java.util.Set) { org.apache.activemq.broker.region.Topic v; java.util.Set v; long v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; byte v; org.apache.activemq.usage.MemoryUsage v; boolean v, v, v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.Topic; v := @parameter: java.util.Set; virtualinvoke v.(v, v); v = specialinvoke v.("memoryLimit", v); if v == 0 goto label; v = v.; v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); label: v = specialinvoke v.("lazyDispatch", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void baseUpdate(org.apache.activemq.broker.region.BaseDestination) { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.BaseDestination v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.BaseDestination; virtualinvoke v.(v, null); return; } public void baseUpdate(org.apache.activemq.broker.region.BaseDestination, java.util.Set) { boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Set v; long v, v, v; int v, v, v, v, v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.BaseDestination v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.BaseDestination; v := @parameter: java.util.Set; v = specialinvoke v.("producerFlowControl", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("alwaysRetroactive", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("blockedProducerWarningInterval", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("maxPageSize", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("maxBrowsePageSize", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("minimumMessageSize", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("maxExpirePageSize", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("cursorMemoryHighWaterMark", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("storeUsageHighWaterMark", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("gcInactiveDestinations", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("gcWithNetworkConsumers", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("inactiveTimeoutBeforeGc", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("reduceMemoryFootprint", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("doOptimizeMessageStore", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("optimizeMessageStoreInFlightLimit", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryForConsumed", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryForDelivery", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryForDiscardingMessages", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryForSlowConsumers", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryForFastProducers", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("advisoryWhenFull", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("includeBodyForAdvisory", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("sendAdvisoryIfNoConsumers", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = specialinvoke v.("sendDuplicateFromStoreToDLQ", v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void baseConfiguration(org.apache.activemq.broker.Broker, org.apache.activemq.broker.region.BaseDestination) { long v, v, v; org.apache.activemq.broker.Broker v; byte v; int v, v, v, v; org.apache.activemq.usage.SystemUsage v, v; boolean v, v, v, v; org.apache.activemq.broker.region.policy.SlowConsumerStrategy v; org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.BaseDestination v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.broker.region.BaseDestination; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; interfaceinvoke v.(v); interfaceinvoke v.(v); label: virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = (int) -1; if v == v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = v cmp -1L; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.region.TopicSubscription) { java.lang.Integer v; org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.TopicSubscription v; boolean v, v, v, v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy v, v; org.apache.activemq.broker.Broker v; int v, v, v, v, v, v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v; org.slf4j.Logger v; org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.region.TopicSubscription; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; if v < 0 goto label; if v >= v goto label; label: v = v; label: if v < 0 goto label; v = ; v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Setting the maximumPendingMessages size to: {} for consumer: {}", v, v); virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001_\u0001"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v, v); virtualinvoke v.(v); label: v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); label: return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.region.DurableTopicSubscription) { org.apache.activemq.util.SubscriptionKey v, v; org.apache.activemq.broker.region.DurableTopicSubscription v; org.apache.activemq.broker.Broker v; int v, v, v, v, v; org.apache.activemq.usage.SystemUsage v; java.lang.String v, v; boolean v, v; org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy v, v; org.apache.activemq.broker.region.cursors.PendingMessageCursor v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.region.DurableTopicSubscription; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v, v); interfaceinvoke v.(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != 10000 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v * 10; virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.region.QueueBrowserSubscription) { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.region.policy.PolicyEntry v; int v, v; org.apache.activemq.usage.SystemUsage v; boolean v; org.apache.activemq.broker.region.QueueBrowserSubscription v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.region.QueueBrowserSubscription; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(2147483647); virtualinvoke v.(32767); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void configure(org.apache.activemq.broker.Broker, org.apache.activemq.usage.SystemUsage, org.apache.activemq.broker.region.QueueSubscription) { org.apache.activemq.broker.Broker v; org.apache.activemq.broker.region.policy.PolicyEntry v; int v, v; org.apache.activemq.usage.SystemUsage v; org.apache.activemq.broker.region.QueueSubscription v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.Broker; v := @parameter: org.apache.activemq.usage.SystemUsage; v := @parameter: org.apache.activemq.broker.region.QueueSubscription; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void configurePrefetch(org.apache.activemq.broker.region.Subscription) { org.apache.activemq.broker.region.Subscription v; org.apache.activemq.broker.region.policy.PolicyEntry v; int v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v; boolean v, v, v, v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.Subscription; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v instanceof org.apache.activemq.broker.region.QueueBrowserSubscription; if v == 0 goto label; if v != 500 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v instanceof org.apache.activemq.broker.region.QueueSubscription; if v == 0 goto label; if v != 1000 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v instanceof org.apache.activemq.broker.region.DurableTopicSubscription; if v == 0 goto label; if v == 100 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 1000 goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v instanceof org.apache.activemq.broker.region.TopicSubscription; if v == 0 goto label; if v != 32767 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.(0); label: return; } private boolean isUpdate(java.lang.String, java.util.Set) { org.apache.activemq.broker.region.policy.PolicyEntry v; java.util.Set v; java.lang.String v; boolean v, v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: java.lang.String; v := @parameter: java.util.Set; if v == null goto label; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.broker.region.policy.DispatchPolicy getDispatchPolicy() { org.apache.activemq.broker.region.policy.DispatchPolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setDispatchPolicy(org.apache.activemq.broker.region.policy.DispatchPolicy) { org.apache.activemq.broker.region.policy.DispatchPolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.DispatchPolicy; v. = v; return; } public org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy getSubscriptionRecoveryPolicy() { org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setSubscriptionRecoveryPolicy(org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy) { org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy; v. = v; return; } public boolean isSendAdvisoryIfNoConsumers() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setSendAdvisoryIfNoConsumers(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isSendDuplicateFromStoreToDLQ() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setSendDuplicateFromStoreToDLQ(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public org.apache.activemq.broker.region.policy.DeadLetterStrategy getDeadLetterStrategy() { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setDeadLetterStrategy(org.apache.activemq.broker.region.policy.DeadLetterStrategy) { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.DeadLetterStrategy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.DeadLetterStrategy; v. = v; return; } public org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy getPendingMessageLimitStrategy() { org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setPendingMessageLimitStrategy(org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy) { org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.PendingMessageLimitStrategy; v. = v; return; } public org.apache.activemq.broker.region.policy.MessageEvictionStrategy getMessageEvictionStrategy() { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMessageEvictionStrategy(org.apache.activemq.broker.region.policy.MessageEvictionStrategy) { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.MessageEvictionStrategy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.MessageEvictionStrategy; v. = v; return; } public long getMemoryLimit() { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMemoryLimit(long) { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: long; v. = v; return; } public org.apache.activemq.broker.region.group.MessageGroupMapFactory getMessageGroupMapFactory() { org.apache.activemq.broker.region.policy.PolicyEntry v; org.slf4j.Logger v; org.apache.activemq.broker.region.group.MessageGroupMapFactory v, v, v; java.lang.String v; java.lang.Exception v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; if v != null goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); v. = v; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to create message group Factory ", v); label: v = v.; return v; catch java.lang.Exception from label to label with label; } public void setMessageGroupMapFactory(org.apache.activemq.broker.region.group.MessageGroupMapFactory) { org.apache.activemq.broker.region.group.MessageGroupMapFactory v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.group.MessageGroupMapFactory; v. = v; return; } public java.lang.String getMessageGroupMapFactoryType() { java.lang.String v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMessageGroupMapFactoryType(java.lang.String) { java.lang.String v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: java.lang.String; v. = v; return; } public org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy getPendingDurableSubscriberPolicy() { org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setPendingDurableSubscriberPolicy(org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy) { org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy; v. = v; return; } public org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy getPendingQueuePolicy() { org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setPendingQueuePolicy(org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy) { org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy; v. = v; return; } public org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy getPendingSubscriberPolicy() { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setPendingSubscriberPolicy(org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy) { org.apache.activemq.broker.region.policy.PolicyEntry v; org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy; v. = v; return; } public boolean isProducerFlowControl() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setProducerFlowControl(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAlwaysRetroactive() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAlwaysRetroactive(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public void setBlockedProducerWarningInterval(long) { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: long; v. = v; return; } public long getBlockedProducerWarningInterval() { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public int getMaxProducersToAudit() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMaxProducersToAudit(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public int getMaxAuditDepth() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMaxAuditDepth(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public boolean isEnableAudit() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setEnableAudit(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public int getMaxQueueAuditDepth() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMaxQueueAuditDepth(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public boolean isOptimizedDispatch() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setOptimizedDispatch(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public int getMaxPageSize() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMaxPageSize(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public int getMaxBrowsePageSize() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMaxBrowsePageSize(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public boolean isUseCache() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setUseCache(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public long getMinimumMessageSize() { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setMinimumMessageSize(long) { long v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: long; v. = v; return; } public boolean isUseConsumerPriority() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setUseConsumerPriority(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isStrictOrderDispatch() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setStrictOrderDispatch(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isLazyDispatch() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setLazyDispatch(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public int getTimeBeforeDispatchStarts() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setTimeBeforeDispatchStarts(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public int getConsumersBeforeDispatchStarts() { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setConsumersBeforeDispatchStarts(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v. = v; return; } public boolean isAdvisoryForSlowConsumers() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryForSlowConsumers(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAdvisoryForDiscardingMessages() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryForDiscardingMessages(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAdvisoryWhenFull() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryWhenFull(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAdvisoryForDelivery() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryForDelivery(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAdvisoryForConsumed() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryForConsumed(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isAdvisoryForFastProducers() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setAdvisoryForFastProducers(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public boolean isIncludeBodyForAdvisory() { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v = v.; return v; } public void setIncludeBodyForAdvisory(boolean) { org.apache.activemq.broker.region.policy.PolicyEntry v; boolean v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: boolean; v. = v; return; } public void setMaxExpirePageSize(int) { int v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.broker.region.policy.PolicyEntry; v := @parameter: int; v.