public interface PriorityQueue<X extends PriorityQueue<X>> extends AMQQueue<X>
MessageSource.ConsumerAccessRefused, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ExistingExclusiveConsumer
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_PRIORITY_LEVELS |
static String |
PRIORITIES |
ALERT_REPEAT_GAP, ALERT_THRESHOLD_MESSAGE_AGE, ALERT_THRESHOLD_MESSAGE_SIZE, ALERT_THRESHOLD_QUEUE_DEPTH_BYTES, ALERT_THRESHOLD_QUEUE_DEPTH_MESSAGES, ALTERNATE_EXCHANGE, CLASS_DESCRIPTION, DEFAULT_ALERT_REPEAT_GAP, DEFAULT_ALERT_THRESHOLD_MESSAGE_AGE, DEFAULT_ALERT_THRESHOLD_MESSAGE_COUNT, DEFAULT_ALERT_THRESHOLD_MESSAGE_SIZE, DEFAULT_ALERT_THRESHOLD_QUEUE_DEPTH, DEFAULT_ESTIMATED_MESSAGE_MEMORY_OVERHEAD, DEFAULT_FILTERS, DEFAULT_FLOW_CONTROL_RESUME_SIZE_BYTES, DEFAULT_FLOW_CONTROL_SIZE_BYTES, DEFAULT_HOLD_ON_PUBLISH_ENABLED, DEFAULT_MAX_ASYNCHRONOUS_DELIVERIES, DEFAULT_MAXIMUM_DELIVERY_ATTEMPTS, DEFAULT_MAXIMUM_DISTINCT_GROUPS, DEFAULT_MINIMUM_ESTIMATED_MEMORY_FOOTPRINT, DEFAULT_SHARED_MESSAGE_GROUP, ENSURE_NONDESTRUCTIVE_CONSUMERS, EXCLUSIVE, HOLD_ON_PUBLISH_ENABLED, MAX_ASYNCHRONOUS_DELIVERIES, MAXIMUM_DELIVERY_ATTEMPTS, MAXIMUM_MESSAGE_TTL, MESSAGE_DURABILITY, MESSAGE_GROUP_DEFAULT_GROUP, MESSAGE_GROUP_KEY, MESSAGE_GROUP_SHARED_GROUPS, MINIMUM_MESSAGE_TTL, NO_LOCAL, OWNER, QUEUE_ESTIMATED_MESSAGE_MEMORY_OVERHEAD, QUEUE_FLOW_CONTROL_SIZE_BYTES, QUEUE_FLOW_RESUME_SIZE_BYTES, QUEUE_FLOW_STOPPED, QUEUE_MINIMUM_ESTIMATED_MEMORY_FOOTPRINT
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
Modifier and Type | Method and Description |
---|---|
int |
getPriorities() |
addBinding, checkMessageStatus, clearQueue, completeRecovery, decrementUnackedMsgCount, deliverAsync, dequeue, getAvailableAttributes, getBindings, getConsumers, getLogSubject, getMessageOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesRangeOnTheQueue, getNotificationChecks, getOldestMessageArrivalTime, getPotentialMemoryFootprint, getVirtualHost, incrementUnackedMsgCount, isDeleted, isEmpty, isExclusive, isUnused, recover, removeBinding, requeue, resend, setNotificationListener, setTargetSize
copyMessages, deleteAndReturnCount, deleteMessages, getAlertRepeatGap, getAlertThresholdMessageAge, getAlertThresholdMessageSize, getAlertThresholdQueueDepthBytes, getAlertThresholdQueueDepthMessages, getAlternateExchange, getBindingCount, getConsumerCount, getConsumerCountWithCredit, getDefaultFilters, getExclusive, getMaximumDeliveryAttempts, getMaximumDistinctGroups, getMaximumMessageTtl, getMessageContent, getMessageDurability, getMessageGroupDefaultGroup, getMessageGroupKey, getMessageInfo, getMessageInfoById, getMinimumMessageTtl, getOldestMessageAge, getOwner, getPersistentDequeuedBytes, getPersistentDequeuedMessages, getPersistentEnqueuedBytes, getPersistentEnqueuedMessages, getQueueDepthBytes, getQueueDepthMessages, getQueueFlowControlSizeBytes, getQueueFlowResumeSizeBytes, getTotalDequeuedBytes, getTotalDequeuedMessages, getTotalEnqueuedBytes, getTotalEnqueuedMessages, getUnacknowledgedBytes, getUnacknowledgedMessages, isEnsureNondestructiveConsumers, isHeld, isHoldOnPublishEnabled, isMessageGroupSharedGroups, isNoLocal, isQueueFlowStopped, moveMessages, visit
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
compareTo
addConsumer, verifySessionAccess
getId, getMessageDurability
checkCapacity
getName, send
addDeleteTask, removeDeleteTask
static final String PRIORITIES
static final int DEFAULT_PRIORITY_LEVELS
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.