Class AddressSettings
java.lang.Object
org.apache.activemq.artemis.core.settings.impl.AddressSettings
- All Implemented Interfaces:
Serializable,EncodingSupport,Mergeable<AddressSettings>
public class AddressSettings
extends Object
implements Mergeable<AddressSettings>, Serializable, EncodingSupport
Configuration settings that are applied on the address level
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final AddressFullMessagePolicystatic final longstatic final booleanstatic final booleanstatic final booleanstatic final booleanDeprecated.static final booleanstatic final booleanDeprecated.static final booleanstatic final longstatic final booleanstatic final booleanstatic final booleanDeprecated.static final booleanstatic final longstatic final longstatic final booleanstatic final booleanDeprecated.static final DeletionPolicystatic final DeletionPolicystatic final DeletionPolicystatic final SimpleStringstatic final SimpleStringstatic final booleanstatic final booleanstatic final longstatic final SimpleStringstatic final SimpleStringstatic final booleanstatic final intstatic final longstatic final intstatic final longdefaults used if null, this allows mergingstatic final longstatic final intstatic final longstatic final booleanstatic final intstatic final intstatic final intstatic final doublestatic final longstatic final doublestatic final longstatic final booleanstatic final longstatic final SlowConsumerPolicystatic final longstatic final SlowConsumerThresholdMeasurementUnitstatic final intstatic final int -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoiddecode(ActiveMQBuffer buffer) voiddecode(ActiveMQBuffer buffer, boolean tryCompatible) voidencode(ActiveMQBuffer buffer) booleanstatic AddressSettingslonglonglongbooleanintintlongintintintintintintlonglonglonglongintintintintintintDeprecated.doublelongdoublelonglonglonglonginthashCode()booleanbooleanbooleanDeprecated.booleanDeprecated.booleanbooleanDeprecated.booleanDeprecated.booleanbooleanbooleanbooleanbooleanbooleanbooleanvoidmerge(AddressSettings merged) Merge two AddressSettings instances in one instancemergeCopy(AddressSettings merged) Merge two AddressSettings instances in a new instancesetAddressFullMessagePolicy(AddressFullMessagePolicy addressFullMessagePolicy) setAutoCreateAddresses(Boolean autoCreateAddresses) setAutoCreateDeadLetterResources(boolean value) setAutoCreateExpiryResources(boolean value) setAutoCreateJmsQueues(boolean autoCreateJmsQueues) Deprecated.setAutoCreateJmsTopics(boolean autoCreateJmsTopics) Deprecated.setAutoCreateQueues(Boolean autoCreateQueues) setAutoDeleteAddresses(Boolean autoDeleteAddresses) setAutoDeleteAddressesDelay(long autoDeleteAddressesDelay) setAutoDeleteAddressesSkipUsageCheck(boolean autoDeleteAddressesSkipUsageCheck) setAutoDeleteCreatedQueues(Boolean autoDeleteCreatedQueues) setAutoDeleteJmsQueues(boolean autoDeleteJmsQueues) Deprecated.setAutoDeleteJmsTopics(boolean autoDeleteJmsTopics) Deprecated.setAutoDeleteQueues(Boolean autoDeleteQueues) setAutoDeleteQueuesDelay(long autoDeleteQueuesDelay) setAutoDeleteQueuesMessageCount(long autoDeleteQueuesMessageCount) setAutoDeleteQueuesSkipUsageCheck(boolean autoDeleteQueuesSkipUsageCheck) setConfigDeleteAddresses(DeletionPolicy configDeleteAddresses) setConfigDeleteDiverts(DeletionPolicy configDeleteDiverts) setConfigDeleteQueues(DeletionPolicy configDeleteQueues) setDeadLetterAddress(SimpleString deadLetterAddress) setDefaultAddressRoutingType(RoutingType defaultAddressRoutingType) setDefaultConsumersBeforeDispatch(Integer defaultConsumersBeforeDispatch) setDefaultConsumerWindowSize(int defaultConsumerWindowSize) setDefaultDelayBeforeDispatch(Long defaultDelayBeforeDispatch) setDefaultExclusiveQueue(Boolean defaultExclusiveQueue) setDefaultGroupBuckets(int defaultGroupBuckets) setDefaultGroupFirstKey(SimpleString defaultGroupFirstKey) setDefaultGroupRebalance(boolean defaultGroupRebalance) setDefaultGroupRebalancePauseDispatch(boolean defaultGroupRebalancePauseDispatch) setDefaultLastValueKey(SimpleString defaultLastValueKey) setDefaultLastValueQueue(boolean defaultLastValueQueue) setDefaultMaxConsumers(Integer defaultMaxConsumers) setDefaultNonDestructive(boolean defaultNonDestructive) setDefaultPurgeOnNoConsumers(Boolean defaultPurgeOnNoConsumers) setDefaultQueueRoutingType(RoutingType defaultQueueRoutingType) setDefaultRingSize(long defaultRingSize) setEnableIngressTimestamp(boolean enableIngressTimestamp) setEnableMetrics(boolean enableMetrics) setExpiryAddress(SimpleString expiryAddress) setExpiryDelay(Long expiryDelay) setExpiryQueuePrefix(SimpleString value) setExpiryQueueSuffix(SimpleString value) setIDCacheSize(Integer idCacheSize) setInitialQueueBufferSize(Integer initialQueueBufferSize) setManagementBrowsePageSize(int managementBrowsePageSize) setManagementMessageAttributeSizeLimit(int managementMessageAttributeSizeLimit) setMaxDeliveryAttempts(int maxDeliveryAttempts) setMaxExpiryDelay(Long maxExpiryDelay) setMaxReadPageBytes(int maxReadPageBytes) setMaxReadPageMessages(int maxReadPageMessages) setMaxRedeliveryDelay(long maxRedeliveryDelay) setMaxSizeBytes(long maxSizeBytes) setMaxSizeBytesRejectThreshold(long maxSizeBytesRejectThreshold) setMaxSizeMessages(long maxSizeMessages) setMessageCounterHistoryDayLimit(int messageCounterHistoryDayLimit) setMinExpiryDelay(Long minExpiryDelay) setNoExpiry(Boolean noExpiry) setPageCacheMaxSize(int pageCacheMaxSize) setPageLimitBytes(Long pageLimitBytes) setPageLimitMessages(Long pageLimitMessages) setPageSizeBytes(int pageSize) setPrefetchPageBytes(int prefetchPageBytes) setPrefetchPageMessages(int prefetchPageMessages) setQueuePrefetch(int queuePrefetch) Deprecated.setRedeliveryCollisionAvoidanceFactor(double redeliveryCollisionAvoidanceFactor) setRedeliveryDelay(long redeliveryDelay) setRedeliveryMultiplier(double redeliveryMultiplier) setRedistributionDelay(long redistributionDelay) setRetroactiveMessageCount(long defaultRetroactiveMessageCount) setSendToDLAOnNoRoute(boolean value) setSlowConsumerCheckPeriod(long slowConsumerCheckPeriod) setSlowConsumerPolicy(SlowConsumerPolicy slowConsumerPolicy) setSlowConsumerThreshold(long slowConsumerThreshold) setSlowConsumerThresholdMeasurementUnit(SlowConsumerThresholdMeasurementUnit slowConsumerThresholdMeasurementUnit) toJSON()toString()
-
Field Details
-
DEFAULT_MAX_SIZE_BYTES
public static final long DEFAULT_MAX_SIZE_BYTESdefaults used if null, this allows merging- See Also:
-
DEFAULT_MAX_SIZE_MESSAGES
public static final long DEFAULT_MAX_SIZE_MESSAGES- See Also:
-
DEFAULT_MAX_READ_PAGE_MESSAGES
public static final int DEFAULT_MAX_READ_PAGE_MESSAGES- See Also:
-
DEFAULT_ADDRESS_FULL_MESSAGE_POLICY
-
DEFAULT_PAGE_SIZE
public static final int DEFAULT_PAGE_SIZE- See Also:
-
DEFAULT_MAX_DELIVERY_ATTEMPTS
public static final int DEFAULT_MAX_DELIVERY_ATTEMPTS- See Also:
-
DEFAULT_PAGE_MAX_CACHE
public static final int DEFAULT_PAGE_MAX_CACHE- See Also:
-
DEFAULT_MESSAGE_COUNTER_HISTORY_DAY_LIMIT
public static final int DEFAULT_MESSAGE_COUNTER_HISTORY_DAY_LIMIT- See Also:
-
DEFAULT_REDELIVER_DELAY
public static final long DEFAULT_REDELIVER_DELAY- See Also:
-
DEFAULT_REDELIVER_MULTIPLIER
public static final double DEFAULT_REDELIVER_MULTIPLIER- See Also:
-
DEFAULT_REDELIVER_COLLISION_AVOIDANCE_FACTOR
public static final double DEFAULT_REDELIVER_COLLISION_AVOIDANCE_FACTOR- See Also:
-
DEFAULT_LAST_VALUE_QUEUE
public static final boolean DEFAULT_LAST_VALUE_QUEUE- See Also:
-
DEFAULT_AUTO_CREATE_JMS_QUEUES
Deprecated.- See Also:
-
DEFAULT_AUTO_DELETE_JMS_QUEUES
Deprecated.- See Also:
-
DEFAULT_AUTO_CREATE_TOPICS
Deprecated.- See Also:
-
DEFAULT_AUTO_DELETE_TOPICS
Deprecated.- See Also:
-
DEFAULT_AUTO_CREATE_QUEUES
public static final boolean DEFAULT_AUTO_CREATE_QUEUES- See Also:
-
DEFAULT_AUTO_DELETE_QUEUES
public static final boolean DEFAULT_AUTO_DELETE_QUEUES- See Also:
-
DEFAULT_AUTO_DELETE_CREATED_QUEUES
public static final boolean DEFAULT_AUTO_DELETE_CREATED_QUEUES- See Also:
-
DEFAULT_AUTO_DELETE_QUEUES_DELAY
public static final long DEFAULT_AUTO_DELETE_QUEUES_DELAY- See Also:
-
DEFAULT_AUTO_DELETE_QUEUES_SKIP_USAGE_CHECK
public static final boolean DEFAULT_AUTO_DELETE_QUEUES_SKIP_USAGE_CHECK- See Also:
-
DEFAULT_AUTO_DELETE_QUEUES_MESSAGE_COUNT
public static final long DEFAULT_AUTO_DELETE_QUEUES_MESSAGE_COUNT- See Also:
-
DEFAULT_CONFIG_DELETE_QUEUES
-
DEFAULT_AUTO_CREATE_ADDRESSES
public static final boolean DEFAULT_AUTO_CREATE_ADDRESSES- See Also:
-
DEFAULT_AUTO_DELETE_ADDRESSES
public static final boolean DEFAULT_AUTO_DELETE_ADDRESSES- See Also:
-
DEFAULT_AUTO_DELETE_ADDRESSES_DELAY
public static final long DEFAULT_AUTO_DELETE_ADDRESSES_DELAY- See Also:
-
DEFAULT_AUTO_DELETE_ADDRESSES_SKIP_USAGE_CHECK
public static final boolean DEFAULT_AUTO_DELETE_ADDRESSES_SKIP_USAGE_CHECK- See Also:
-
DEFAULT_CONFIG_DELETE_ADDRESSES
-
DEFAULT_CONFIG_DELETE_DIVERTS
-
DEFAULT_REDISTRIBUTION_DELAY
public static final long DEFAULT_REDISTRIBUTION_DELAY- See Also:
-
DEFAULT_AUTO_CREATE_EXPIRY_RESOURCES
public static final boolean DEFAULT_AUTO_CREATE_EXPIRY_RESOURCES- See Also:
-
DEFAULT_EXPIRY_QUEUE_PREFIX
-
DEFAULT_EXPIRY_QUEUE_SUFFIX
-
DEFAULT_EXPIRY_DELAY
public static final long DEFAULT_EXPIRY_DELAY- See Also:
-
DEFAULT_MIN_EXPIRY_DELAY
public static final long DEFAULT_MIN_EXPIRY_DELAY- See Also:
-
DEFAULT_MAX_EXPIRY_DELAY
public static final long DEFAULT_MAX_EXPIRY_DELAY- See Also:
-
DEFAULT_NO_EXPIRY
public static final boolean DEFAULT_NO_EXPIRY- See Also:
-
DEFAULT_SEND_TO_DLA_ON_NO_ROUTE
public static final boolean DEFAULT_SEND_TO_DLA_ON_NO_ROUTE- See Also:
-
DEFAULT_SLOW_CONSUMER_THRESHOLD
public static final long DEFAULT_SLOW_CONSUMER_THRESHOLD- See Also:
-
DEFAULT_SLOW_CONSUMER_CHECK_PERIOD
public static final long DEFAULT_SLOW_CONSUMER_CHECK_PERIOD- See Also:
-
MANAGEMENT_BROWSE_PAGE_SIZE
public static final int MANAGEMENT_BROWSE_PAGE_SIZE- See Also:
-
DEFAULT_SLOW_CONSUMER_POLICY
-
DEFAULT_QUEUE_PREFETCH
public static final int DEFAULT_QUEUE_PREFETCH- See Also:
-
DEFAULT_ADDRESS_REJECT_THRESHOLD
public static final long DEFAULT_ADDRESS_REJECT_THRESHOLD- See Also:
-
DEFAULT_AUTO_CREATE_DEAD_LETTER_RESOURCES
public static final boolean DEFAULT_AUTO_CREATE_DEAD_LETTER_RESOURCES- See Also:
-
DEFAULT_DEAD_LETTER_QUEUE_PREFIX
-
DEFAULT_DEAD_LETTER_QUEUE_SUFFIX
-
DEFAULT_ENABLE_METRICS
public static final boolean DEFAULT_ENABLE_METRICS- See Also:
-
MANAGEMENT_MESSAGE_ATTRIBUTE_SIZE_LIMIT
public static final int MANAGEMENT_MESSAGE_ATTRIBUTE_SIZE_LIMIT- See Also:
-
DEFAULT_SLOW_CONSUMER_THRESHOLD_MEASUREMENT_UNIT
public static final SlowConsumerThresholdMeasurementUnit DEFAULT_SLOW_CONSUMER_THRESHOLD_MEASUREMENT_UNIT -
DEFAULT_ENABLE_INGRESS_TIMESTAMP
public static final boolean DEFAULT_ENABLE_INGRESS_TIMESTAMP- See Also:
-
-
Constructor Details
-
AddressSettings
-
AddressSettings
public AddressSettings()
-
-
Method Details
-
isAutoCreateJmsQueues
Deprecated. -
toJSON
-
fromJSON
-
setAutoCreateJmsQueues
Deprecated. -
isAutoDeleteJmsQueues
Deprecated. -
setAutoDeleteJmsQueues
Deprecated. -
isAutoCreateJmsTopics
Deprecated. -
setAutoCreateJmsTopics
Deprecated. -
isAutoDeleteJmsTopics
Deprecated. -
setAutoDeleteJmsTopics
Deprecated. -
isAutoCreateQueues
-
setAutoCreateQueues
-
isAutoDeleteQueues
-
setAutoDeleteQueues
-
setAutoDeleteCreatedQueues
-
isAutoDeleteCreatedQueues
-
getAutoDeleteQueuesDelay
public long getAutoDeleteQueuesDelay() -
setAutoDeleteQueuesDelay
-
getAutoDeleteQueuesSkipUsageCheck
public boolean getAutoDeleteQueuesSkipUsageCheck() -
setAutoDeleteQueuesSkipUsageCheck
-
getAutoDeleteQueuesMessageCount
public long getAutoDeleteQueuesMessageCount() -
setAutoDeleteQueuesMessageCount
-
getConfigDeleteQueues
-
setConfigDeleteQueues
-
isAutoCreateAddresses
-
setAutoCreateAddresses
-
isAutoDeleteAddresses
-
setAutoDeleteAddresses
-
getAutoDeleteAddressesDelay
public long getAutoDeleteAddressesDelay() -
setAutoDeleteAddressesDelay
-
isAutoDeleteAddressesSkipUsageCheck
public boolean isAutoDeleteAddressesSkipUsageCheck() -
setAutoDeleteAddressesSkipUsageCheck
public AddressSettings setAutoDeleteAddressesSkipUsageCheck(boolean autoDeleteAddressesSkipUsageCheck) -
getConfigDeleteAddresses
-
setConfigDeleteAddresses
-
setConfigDeleteDiverts
-
getConfigDeleteDiverts
-
getDefaultMaxConsumers
-
setDefaultMaxConsumers
-
getDefaultConsumersBeforeDispatch
-
setDefaultConsumersBeforeDispatch
-
getDefaultDelayBeforeDispatch
-
setDefaultDelayBeforeDispatch
-
isDefaultPurgeOnNoConsumers
-
setDefaultPurgeOnNoConsumers
-
getDefaultQueueRoutingType
-
setDefaultQueueRoutingType
-
getDefaultAddressRoutingType
-
setDefaultAddressRoutingType
-
isDefaultLastValueQueue
public boolean isDefaultLastValueQueue() -
setDefaultLastValueQueue
-
getDefaultLastValueKey
-
setDefaultLastValueKey
-
isDefaultNonDestructive
public boolean isDefaultNonDestructive() -
setDefaultNonDestructive
-
isDefaultExclusiveQueue
-
setDefaultExclusiveQueue
-
getAddressFullMessagePolicy
-
setAddressFullMessagePolicy
public AddressSettings setAddressFullMessagePolicy(AddressFullMessagePolicy addressFullMessagePolicy) -
getPageSizeBytes
public int getPageSizeBytes() -
setPageSizeBytes
-
getPageCacheMaxSize
public int getPageCacheMaxSize() -
setPageCacheMaxSize
-
getMaxSizeBytes
public long getMaxSizeBytes() -
getMaxSizeMessages
public long getMaxSizeMessages() -
setMaxSizeMessages
-
setMaxSizeBytes
-
getMaxReadPageMessages
public int getMaxReadPageMessages() -
setMaxReadPageMessages
-
getPrefetchPageMessages
public int getPrefetchPageMessages() -
setPrefetchPageMessages
-
getPageLimitBytes
-
setPageLimitBytes
-
getPageLimitMessages
-
setPageLimitMessages
-
getPageFullMessagePolicy
-
setPageFullMessagePolicy
-
getMaxReadPageBytes
public int getMaxReadPageBytes() -
setMaxReadPageBytes
-
getPrefetchPageBytes
public int getPrefetchPageBytes() -
setPrefetchPageBytes
-
getMaxDeliveryAttempts
public int getMaxDeliveryAttempts() -
setMaxDeliveryAttempts
-
getMessageCounterHistoryDayLimit
public int getMessageCounterHistoryDayLimit() -
setMessageCounterHistoryDayLimit
-
getRedeliveryDelay
public long getRedeliveryDelay() -
setRedeliveryDelay
-
getRedeliveryMultiplier
public double getRedeliveryMultiplier() -
setRedeliveryMultiplier
-
getRedeliveryCollisionAvoidanceFactor
public double getRedeliveryCollisionAvoidanceFactor() -
setRedeliveryCollisionAvoidanceFactor
public AddressSettings setRedeliveryCollisionAvoidanceFactor(double redeliveryCollisionAvoidanceFactor) -
getMaxRedeliveryDelay
public long getMaxRedeliveryDelay() -
setMaxRedeliveryDelay
-
getDeadLetterAddress
-
setDeadLetterAddress
-
getExpiryAddress
-
setExpiryAddress
-
isAutoCreateExpiryResources
public boolean isAutoCreateExpiryResources() -
setAutoCreateExpiryResources
-
getExpiryQueuePrefix
-
setExpiryQueuePrefix
-
getExpiryQueueSuffix
-
setExpiryQueueSuffix
-
getExpiryDelay
-
setExpiryDelay
-
getMinExpiryDelay
-
setMinExpiryDelay
-
getMaxExpiryDelay
-
setMaxExpiryDelay
-
isNoExpiry
-
setNoExpiry
-
isSendToDLAOnNoRoute
public boolean isSendToDLAOnNoRoute() -
setSendToDLAOnNoRoute
-
isAutoCreateDeadLetterResources
public boolean isAutoCreateDeadLetterResources() -
setAutoCreateDeadLetterResources
-
getDeadLetterQueuePrefix
-
setDeadLetterQueuePrefix
-
getDeadLetterQueueSuffix
-
setDeadLetterQueueSuffix
-
getRedistributionDelay
public long getRedistributionDelay() -
setRedistributionDelay
-
getSlowConsumerThreshold
public long getSlowConsumerThreshold() -
setSlowConsumerThreshold
-
getSlowConsumerThresholdMeasurementUnit
-
setSlowConsumerThresholdMeasurementUnit
public AddressSettings setSlowConsumerThresholdMeasurementUnit(SlowConsumerThresholdMeasurementUnit slowConsumerThresholdMeasurementUnit) -
getSlowConsumerCheckPeriod
public long getSlowConsumerCheckPeriod() -
setSlowConsumerCheckPeriod
-
getSlowConsumerPolicy
-
setSlowConsumerPolicy
-
getManagementBrowsePageSize
public int getManagementBrowsePageSize() -
setManagementBrowsePageSize
-
getQueuePrefetch
Deprecated. -
setQueuePrefetch
Deprecated. -
getMaxSizeBytesRejectThreshold
public long getMaxSizeBytesRejectThreshold() -
setMaxSizeBytesRejectThreshold
-
getDefaultConsumerWindowSize
public int getDefaultConsumerWindowSize() -
setDefaultConsumerWindowSize
-
isDefaultGroupRebalance
public boolean isDefaultGroupRebalance() -
setDefaultGroupRebalance
-
isDefaultGroupRebalancePauseDispatch
public boolean isDefaultGroupRebalancePauseDispatch() -
setDefaultGroupRebalancePauseDispatch
public AddressSettings setDefaultGroupRebalancePauseDispatch(boolean defaultGroupRebalancePauseDispatch) -
getDefaultGroupBuckets
public int getDefaultGroupBuckets() -
getDefaultGroupFirstKey
-
setDefaultGroupFirstKey
-
setDefaultGroupBuckets
-
getDefaultRingSize
public long getDefaultRingSize() -
setDefaultRingSize
-
getRetroactiveMessageCount
public long getRetroactiveMessageCount() -
setRetroactiveMessageCount
-
isEnableMetrics
public boolean isEnableMetrics() -
setEnableMetrics
-
getManagementMessageAttributeSizeLimit
public int getManagementMessageAttributeSizeLimit() -
setManagementMessageAttributeSizeLimit
public AddressSettings setManagementMessageAttributeSizeLimit(int managementMessageAttributeSizeLimit) -
isEnableIngressTimestamp
public boolean isEnableIngressTimestamp() -
setEnableIngressTimestamp
-
getIDCacheSize
-
setIDCacheSize
-
getInitialQueueBufferSize
-
setInitialQueueBufferSize
-
merge
Merge two AddressSettings instances in one instance- Specified by:
mergein interfaceMergeable<AddressSettings>
-
mergeCopy
Merge two AddressSettings instances in a new instance- Specified by:
mergeCopyin interfaceMergeable<AddressSettings>
-
decode
- Specified by:
decodein interfaceEncodingSupport
-
decode
-
getEncodeSize
public int getEncodeSize()- Specified by:
getEncodeSizein interfaceEncodingSupport
-
encode
- Specified by:
encodein interfaceEncodingSupport
-
equals
-
hashCode
public int hashCode() -
toString
-