public class SortedQueueImpl extends OutOfOrderQueue<SortedQueueImpl> implements SortedQueue<SortedQueueImpl>
AbstractQueue.MessageContent, AbstractQueue.QueueEntryFilterAbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameExceptionMessageSource.ConsumerAccessRefused, MessageSource.ExistingConsumerPreventsExclusive, MessageSource.ExistingExclusiveConsumerSHARED_MSG_GROUP_ARG_VALUESECURED_STRING_VALUESORT_KEY, SORTED_QUEUE_TYPEALERT_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_FOOTPRINTCONTEXT, 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 |
|---|
SortedQueueImpl(Map<String,Object> attributes,
VirtualHostImpl virtualHost) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
String |
getSortKey() |
protected void |
onOpen() |
checkConsumersNotAheadOfDeliveryaddBinding, addChildAsync, addConsumer, addDeleteTask, advanceAllConsumers, beforeClose, changeAttribute, checkCapacity, checkMessageStatus, clearQueue, compareTo, completeRecovery, copyMessages, decrementUnackedMsgCount, deleteAndReturnCount, deleteMessages, deliverAsync, dequeue, enqueue, execute, getAlertRepeatGap, getAlertThresholdMessageAge, getAlertThresholdMessageSize, getAlertThresholdQueueDepthBytes, getAlertThresholdQueueDepthMessages, getAlternateExchange, getAtomicQueueCount, getAtomicQueueSize, getAvailableAttributes, getBindingCount, getBindings, getChildren, getConsumerCount, getConsumerCountWithCredit, getConsumerList, getConsumers, getCreatedLogMessage, 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, visitaddChangeListener, 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, validateOnCreateclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddBinding, 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, setTargetSizecopyMessages, 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, visitaddChangeListener, 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, setAttributesAsynccompareToaddConsumer, verifySessionAccessgetId, getMessageDurabilitycheckCapacitygetName, sendaddDeleteTask, removeDeleteTaskpublic SortedQueueImpl(Map<String,Object> attributes, VirtualHostImpl virtualHost)
protected void onOpen()
onOpen in class AbstractQueue<SortedQueueImpl>protected void doEnqueue(ServerMessage message, Action<? super MessageInstance> action, MessageEnqueueRecord record)
doEnqueue in class AbstractQueue<SortedQueueImpl>public String getSortKey()
getSortKey in interface SortedQueue<SortedQueueImpl>Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.