public interface Queue<X extends Queue<X>> extends ConfiguredObject<X>
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
static final String CLASS_DESCRIPTION
static final String ALERT_REPEAT_GAP
static final String ALERT_THRESHOLD_MESSAGE_AGE
static final String ALERT_THRESHOLD_MESSAGE_SIZE
static final String ALERT_THRESHOLD_QUEUE_DEPTH_BYTES
static final String ALERT_THRESHOLD_QUEUE_DEPTH_MESSAGES
static final String ALTERNATE_EXCHANGE
static final String EXCLUSIVE
static final String MESSAGE_DURABILITY
static final String MESSAGE_GROUP_KEY
static final String MESSAGE_GROUP_SHARED_GROUPS
static final String MESSAGE_GROUP_DEFAULT_GROUP
static final String MAXIMUM_DELIVERY_ATTEMPTS
static final String NO_LOCAL
static final String OWNER
static final String QUEUE_FLOW_CONTROL_SIZE_BYTES
static final String QUEUE_FLOW_RESUME_SIZE_BYTES
static final String QUEUE_FLOW_STOPPED
static final String MAXIMUM_MESSAGE_TTL
static final String MINIMUM_MESSAGE_TTL
static final String DEFAULT_FILTERS
static final String ENSURE_NONDESTRUCTIVE_CONSUMERS
static final String HOLD_ON_PUBLISH_ENABLED
static final String QUEUE_MINIMUM_ESTIMATED_MEMORY_FOOTPRINT
static final long DEFAULT_MINIMUM_ESTIMATED_MEMORY_FOOTPRINT
static final String QUEUE_ESTIMATED_MESSAGE_MEMORY_OVERHEAD
static final long DEFAULT_ESTIMATED_MESSAGE_MEMORY_OVERHEAD
static final String MAX_ASYNCHRONOUS_DELIVERIES
static final int DEFAULT_MAX_ASYNCHRONOUS_DELIVERIES
static final String DEFAULT_SHARED_MESSAGE_GROUP
static final int DEFAULT_MAXIMUM_DISTINCT_GROUPS
static final int DEFAULT_MAXIMUM_DELIVERY_ATTEMPTS
static final long DEFAULT_FLOW_CONTROL_SIZE_BYTES
static final long DEFAULT_FLOW_CONTROL_RESUME_SIZE_BYTES
static final long DEFAULT_ALERT_THRESHOLD_MESSAGE_AGE
static final long DEFAULT_ALERT_THRESHOLD_MESSAGE_SIZE
static final long DEFAULT_ALERT_THRESHOLD_QUEUE_DEPTH
static final long DEFAULT_ALERT_THRESHOLD_MESSAGE_COUNT
static final long DEFAULT_ALERT_REPEAT_GAP
static final boolean DEFAULT_HOLD_ON_PUBLISH_ENABLED
Exchange getAlternateExchange()
ExclusivityPolicy getExclusive()
boolean isEnsureNondestructiveConsumers()
String getOwner()
boolean isNoLocal()
String getMessageGroupKey()
String getMessageGroupDefaultGroup()
int getMaximumDistinctGroups()
boolean isMessageGroupSharedGroups()
int getMaximumDeliveryAttempts()
long getQueueFlowControlSizeBytes()
long getQueueFlowResumeSizeBytes()
boolean isQueueFlowStopped()
long getAlertThresholdMessageAge()
long getAlertThresholdMessageSize()
long getAlertThresholdQueueDepthBytes()
long getAlertThresholdQueueDepthMessages()
long getAlertRepeatGap()
MessageDurability getMessageDurability()
long getMinimumMessageTtl()
long getMaximumMessageTtl()
boolean isHoldOnPublishEnabled()
Collection<? extends Binding> getBindings()
Collection<? extends Consumer> getConsumers()
void visit(QueueEntryVisitor visitor)
com.google.common.util.concurrent.ListenableFuture<Integer> deleteAndReturnCount()
void setNotificationListener(QueueNotificationListener listener)
int getBindingCount()
int getConsumerCount()
int getConsumerCountWithCredit()
long getPersistentDequeuedBytes()
long getPersistentDequeuedMessages()
long getPersistentEnqueuedBytes()
long getPersistentEnqueuedMessages()
long getQueueDepthBytes()
int getQueueDepthMessages()
long getTotalDequeuedBytes()
long getTotalDequeuedMessages()
long getTotalEnqueuedBytes()
long getTotalEnqueuedMessages()
long getUnacknowledgedBytes()
long getUnacknowledgedMessages()
long getOldestMessageAge()
List<Long> moveMessages(Queue<?> destination, List<Long> messageIds, String selector, int limit)
List<Long> copyMessages(Queue<?> destination, List<Long> messageIds, String selector, int limit)
long clearQueue()
Content getMessageContent(long messageId)
List<MessageInfo> getMessageInfo(int first, int last)
MessageInfo getMessageInfoById(long messageId)
boolean isHeld(QueueEntry queueEntry, long evaluationTime)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.