public class PriorityQueueImpl extends OutOfOrderQueue<PriorityQueueImpl> implements PriorityQueue<PriorityQueueImpl>
AbstractQueue.MessageContent, AbstractQueue.QueueEntryFilter
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
MessageSource.ConsumerAccessRefused, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ExistingExclusiveConsumer
SHARED_MSG_GROUP_ARG_VALUE
SECURED_STRING_VALUE
DEFAULT_PRIORITY_LEVELS, 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
Constructor and Description |
---|
PriorityQueueImpl(Map<String,Object> attributes,
VirtualHostImpl virtualHost) |
Modifier and Type | Method and Description |
---|---|
protected LogMessage |
getCreatedLogMessage() |
int |
getPriorities() |
protected void |
onOpen() |
checkConsumersNotAheadOfDelivery
addBinding, addChildAsync, addConsumer, addDeleteTask, advanceAllConsumers, beforeClose, changeAttribute, checkCapacity, checkMessageStatus, clearQueue, compareTo, completeRecovery, copyMessages, decrementUnackedMsgCount, deleteAndReturnCount, deleteMessages, deliverAsync, dequeue, doEnqueue, enqueue, execute, getAlertRepeatGap, getAlertThresholdMessageAge, getAlertThresholdMessageSize, getAlertThresholdQueueDepthBytes, getAlertThresholdQueueDepthMessages, getAlternateExchange, getAtomicQueueCount, getAtomicQueueSize, getAvailableAttributes, getBindingCount, getBindings, getChildren, getConsumerCount, getConsumerCountWithCredit, getConsumerList, getConsumers, getDefaultFilters, getEventLogger, getExclusive, getLogSubject, getMaximumDeliveryAttempts, getMaximumDistinctGroups, getMaximumMessageTtl, getMessageContent, getMessageDurability, getMessageGroupDefaultGroup, getMessageGroupKey, getMessageInfo, getMessageInfoById, getMessageOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesRangeOnTheQueue, getMinimumMessageTtl, getNotificationChecks, getOldestMessageAge, getOldestMessageArrivalTime, getOwner, getPersistentDequeuedBytes, getPersistentDequeuedMessages, getPersistentEnqueuedBytes, getPersistentEnqueuedMessages, getPotentialMemoryFootprint, getQueueDepthBytes, getQueueDepthMessages, getQueueFlowControlSizeBytes, getQueueFlowResumeSizeBytes, getReceivedMessageCount, getTotalDequeuedBytes, getTotalDequeuedMessages, getTotalEnqueuedBytes, getTotalEnqueuedMessages, getUnacknowledgedBytes, getUnacknowledgedMessages, getUndeliveredMessageCount, getVirtualHost, incrementUnackedMsgCount, isDeleted, isEmpty, isEnsureNondestructiveConsumers, isEntryAheadOfConsumer, isExclusive, isHeld, isHoldOnPublishEnabled, isMessageGroupSharedGroups, isNoLocal, isQueueFlowStopped, isUnused, moveMessages, onClose, onCreate, onValidate, processQueue, recover, removeBinding, removeDeleteTask, requeue, resend, resetSubPointersForGroups, resetSubPointersForGroups, send, setAlternateExchange, setNotificationListener, setTargetSize, stateChanged, toString, validateChange, verifySessionAccess, visit
addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onExceptionInOpen, onResolve, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, validateOnCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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
public PriorityQueueImpl(Map<String,Object> attributes, VirtualHostImpl virtualHost)
protected void onOpen()
onOpen
in class AbstractQueue<PriorityQueueImpl>
public int getPriorities()
getPriorities
in interface PriorityQueue<PriorityQueueImpl>
protected LogMessage getCreatedLogMessage()
getCreatedLogMessage
in class AbstractQueue<PriorityQueueImpl>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.