org.apache.activemq.apollo.dto
Class QueueSettingsDTO

java.lang.Object
  extended by org.apache.activemq.apollo.dto.QueueSettingsDTO
Direct Known Subclasses:
QueueDTO

public class QueueSettingsDTO
extends java.lang.Object

Author:
Hiram Chirino

Field Summary
 java.lang.String catchup_enqueue_rate
          If set, and the the current delivery rate is exceeding the configured value of fast_delivery_rate and the consumers are spending more time loading from the store than delivering, then the enqueue rate will be throttled to the specified value so that the consumers can catch up and reach the tail of the queue.
 java.lang.String dlq
          Is the dead letter queue configured for the destination.
 java.lang.String fast_delivery_rate
          The message delivery rate (in bytes/sec) at which the queue considers the consumers fast and may start slowing down producers to match the consumption rate if the consumers are at the tail of the queue.
 java.lang.String full_policy
          Once the queue is full, the `full_policy` controls how the queue behaves when additional messages attempt to be enqueued onto the queue.
 java.lang.String max_enqueue_rate
          The maximum enqueue rate of the queue
 java.lang.Integer nak_limit
          Once a message has been nacked the configured number of times the message will be considered to be a poison message and will get moved to the dead letter queue if that's configured or dropped.
 java.util.List<java.lang.Object> other
          To hold any other non-matching XML elements
 java.lang.Boolean persistent
          Should this queue persistently store it's entries?
 java.lang.String quota
          The maximum amount of size the queue is allowed to grow to.
 java.lang.Boolean swap
          Should messages be swapped out of memory if no consumers need the message?
 java.lang.Integer swap_range_size
          The number max number of swapped queue entries to load from the store at a time.
 java.lang.String tail_buffer
          The amount of memory buffer space to use for swapping messages out.
 
Constructor Summary
QueueSettingsDTO()
           
 
Method Summary
 boolean equals(java.lang.Object o)
           
 int hashCode()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

tail_buffer

public java.lang.String tail_buffer
The amount of memory buffer space to use for swapping messages out.


persistent

public java.lang.Boolean persistent
Should this queue persistently store it's entries?


swap

public java.lang.Boolean swap
Should messages be swapped out of memory if no consumers need the message?


swap_range_size

public java.lang.Integer swap_range_size
The number max number of swapped queue entries to load from the store at a time. Note that swapped entries are just reference pointers to the actual messages. When not loaded, the batch is referenced as sequence range to conserve memory.


quota

public java.lang.String quota
The maximum amount of size the queue is allowed to grow to. If not set then there is no limit. You can use settings values like: 500mb or 1g just plain 1024000


full_policy

public java.lang.String full_policy
Once the queue is full, the `full_policy` controls how the queue behaves when additional messages attempt to be enqueued onto the queue. You can set it to one of the following options: `block`: The producer blocks until some space frees up. `drop tail`: Drops new messages being enqueued on the queue. `drop head`: Drops old messages at the front of the queue. If the queue is persistent then it is considered full when the max quota size is reached. If the queue is not persistent then the queue is considered full once it's `tail_buffer` fills up. Defaults to 'block' if not specified.


fast_delivery_rate

public java.lang.String fast_delivery_rate
The message delivery rate (in bytes/sec) at which the queue considers the consumers fast and may start slowing down producers to match the consumption rate if the consumers are at the tail of the queue.


catchup_enqueue_rate

public java.lang.String catchup_enqueue_rate
If set, and the the current delivery rate is exceeding the configured value of fast_delivery_rate and the consumers are spending more time loading from the store than delivering, then the enqueue rate will be throttled to the specified value so that the consumers can catch up and reach the tail of the queue.


max_enqueue_rate

public java.lang.String max_enqueue_rate
The maximum enqueue rate of the queue


dlq

public java.lang.String dlq
Is the dead letter queue configured for the destination. A dead letter queue is used for storing messages that failed to get processed by consumers. If not set, then messages that fail to get processed will be dropped. If '*' appears in the name it will be replaced with the queue's id.


nak_limit

public java.lang.Integer nak_limit
Once a message has been nacked the configured number of times the message will be considered to be a poison message and will get moved to the dead letter queue if that's configured or dropped. If set to less than one, then the message will never be considered to be a poison message. Defaults to zero.


other

public java.util.List<java.lang.Object> other
To hold any other non-matching XML elements

Constructor Detail

QueueSettingsDTO

public QueueSettingsDTO()
Method Detail

equals

public boolean equals(java.lang.Object o)
Overrides:
equals in class java.lang.Object

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.