public class AddressSetting<T extends AddressSetting<T>> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AddressSetting.AddressFullPolicy |
static class |
AddressSetting.SlowConsumerPolicy |
Constructor and Description |
---|
AddressSetting(String key) |
Modifier and Type | Method and Description |
---|---|
void |
addPropertyChangeListener(PropertyChangeListener listener)
Adds a property change listener
|
AddressSetting.AddressFullPolicy |
addressFullPolicy()
Determines what happens when an address where max-size-bytes is specified
becomes full.
|
T |
addressFullPolicy(AddressSetting.AddressFullPolicy value)
Determines what happens when an address where max-size-bytes is specified
becomes full.
|
Boolean |
autoCreateAddresses()
Determines whether ActiveMQ should automatically create an addresses
corresponding to the address-settings match when a producer or a consumer
is tries to use such a queue.
|
T |
autoCreateAddresses(Boolean value)
Determines whether ActiveMQ should automatically create an addresses
corresponding to the address-settings match when a producer or a consumer
is tries to use such a queue.
|
Boolean |
autoCreateQueues()
Determines whether ActiveMQ should automatically create a queue
corresponding to the address-settings match when a producer or a consumer
is tries to use such a queue.
|
T |
autoCreateQueues(Boolean value)
Determines whether ActiveMQ should automatically create a queue
corresponding to the address-settings match when a producer or a consumer
is tries to use such a queue.
|
Boolean |
autoDeleteAddresses()
Determines Whether ActiveMQ should automatically delete auto-created
addresses when they have no consumers and no messages.
|
T |
autoDeleteAddresses(Boolean value)
Determines Whether ActiveMQ should automatically delete auto-created
addresses when they have no consumers and no messages.
|
Boolean |
autoDeleteQueues()
Determines Whether ActiveMQ should automatically delete auto-created
queues when they have no consumers and no messages.
|
T |
autoDeleteQueues(Boolean value)
Determines Whether ActiveMQ should automatically delete auto-created
queues when they have no consumers and no messages.
|
String |
deadLetterAddress()
The dead letter address
|
T |
deadLetterAddress(String value)
The dead letter address
|
String |
expiryAddress()
Defines where to send a message that has expired.
|
T |
expiryAddress(String value)
Defines where to send a message that has expired.
|
Long |
expiryDelay()
Defines the expiration time that will be used for messages using the
default expiration time
|
T |
expiryDelay(Long value)
Defines the expiration time that will be used for messages using the
default expiration time
|
String |
getKey() |
Boolean |
lastValueQueue()
Defines whether a queue only uses last values or not
|
T |
lastValueQueue(Boolean value)
Defines whether a queue only uses last values or not
|
Integer |
maxDeliveryAttempts()
Defines how many time a cancelled message can be redelivered before
sending to the dead-letter-address
|
T |
maxDeliveryAttempts(Integer value)
Defines how many time a cancelled message can be redelivered before
sending to the dead-letter-address
|
Long |
maxRedeliveryDelay()
Maximum value for the redelivery-delay (in ms).
|
T |
maxRedeliveryDelay(Long value)
Maximum value for the redelivery-delay (in ms).
|
Long |
maxSizeBytes()
The max bytes size.
|
T |
maxSizeBytes(Long value)
The max bytes size.
|
Integer |
messageCounterHistoryDayLimit()
Day limit for the message counter history.
|
T |
messageCounterHistoryDayLimit(Integer value)
Day limit for the message counter history.
|
Integer |
pageMaxCacheSize()
The number of page files to keep in memory to optimize IO during paging
navigation.
|
T |
pageMaxCacheSize(Integer value)
The number of page files to keep in memory to optimize IO during paging
navigation.
|
Long |
pageSizeBytes()
The paging size.
|
T |
pageSizeBytes(Long value)
The paging size.
|
Long |
redeliveryDelay()
Defines how long to wait before attempting redelivery of a cancelled
message
|
T |
redeliveryDelay(Long value)
Defines how long to wait before attempting redelivery of a cancelled
message
|
Double |
redeliveryMultiplier()
Multiplier to apply to the redelivery-delay parameter
|
T |
redeliveryMultiplier(Double value)
Multiplier to apply to the redelivery-delay parameter
|
Long |
redistributionDelay()
Defines how long to wait when the last consumer is closed on a queue
before redistributing any messages
|
T |
redistributionDelay(Long value)
Defines how long to wait when the last consumer is closed on a queue
before redistributing any messages
|
void |
removePropertyChangeListener(PropertyChangeListener listener)
Removes a property change listener
|
Boolean |
sendToDlaOnNoRoute()
If this parameter is set to true for that address, if the message is not
routed to any queues it will instead be sent to the dead letter address
(DLA) for that address, if it exists.
|
T |
sendToDlaOnNoRoute(Boolean value)
If this parameter is set to true for that address, if the message is not
routed to any queues it will instead be sent to the dead letter address
(DLA) for that address, if it exists.
|
Long |
slowConsumerCheckPeriod()
How often to check for slow consumers on a particular queue.
|
T |
slowConsumerCheckPeriod(Long value)
How often to check for slow consumers on a particular queue.
|
AddressSetting.SlowConsumerPolicy |
slowConsumerPolicy()
Determine what happens when a slow consumer is identified.
|
T |
slowConsumerPolicy(AddressSetting.SlowConsumerPolicy value)
Determine what happens when a slow consumer is identified.
|
Long |
slowConsumerThreshold()
The minimum rate of message consumption allowed before a consumer is
considered slow.
|
T |
slowConsumerThreshold(Long value)
The minimum rate of message consumption allowed before a consumer is
considered slow.
|
public AddressSetting(String key)
public String getKey()
public void addPropertyChangeListener(PropertyChangeListener listener)
public void removePropertyChangeListener(PropertyChangeListener listener)
public AddressSetting.AddressFullPolicy addressFullPolicy()
public T addressFullPolicy(AddressSetting.AddressFullPolicy value)
public Boolean autoCreateAddresses()
public T autoCreateAddresses(Boolean value)
public Boolean autoCreateQueues()
public T autoCreateQueues(Boolean value)
public Boolean autoDeleteAddresses()
public T autoDeleteAddresses(Boolean value)
public Boolean autoDeleteQueues()
public T autoDeleteQueues(Boolean value)
public String deadLetterAddress()
public String expiryAddress()
public T expiryAddress(String value)
public Long expiryDelay()
public T expiryDelay(Long value)
public Boolean lastValueQueue()
public T lastValueQueue(Boolean value)
public Integer maxDeliveryAttempts()
public T maxDeliveryAttempts(Integer value)
public Long maxRedeliveryDelay()
public T maxRedeliveryDelay(Long value)
public Long maxSizeBytes()
public Integer messageCounterHistoryDayLimit()
public T messageCounterHistoryDayLimit(Integer value)
public Integer pageMaxCacheSize()
public T pageMaxCacheSize(Integer value)
public Long pageSizeBytes()
public Long redeliveryDelay()
public T redeliveryDelay(Long value)
public Double redeliveryMultiplier()
public T redeliveryMultiplier(Double value)
public Long redistributionDelay()
public T redistributionDelay(Long value)
public Boolean sendToDlaOnNoRoute()
public T sendToDlaOnNoRoute(Boolean value)
public Long slowConsumerCheckPeriod()
public T slowConsumerCheckPeriod(Long value)
public AddressSetting.SlowConsumerPolicy slowConsumerPolicy()
public T slowConsumerPolicy(AddressSetting.SlowConsumerPolicy value)
public Long slowConsumerThreshold()
Copyright © 2019 JBoss by Red Hat. All rights reserved.