public class LastValueQueueImpl extends AbstractQueue<LastValueQueueImpl> implements LastValueQueue<LastValueQueueImpl>
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_LVQ_KEY, LAST_VALUE_QUEUE_TYPE, LVQ_KEY
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 |
---|
LastValueQueueImpl(Map<String,Object> attributes,
VirtualHostImpl virtualHost) |
Modifier and Type | Method and Description |
---|---|
String |
getLvqKey() |
protected void |
onOpen() |
addBinding, addChildAsync, addConsumer, addDeleteTask, advanceAllConsumers, beforeClose, changeAttribute, checkCapacity, checkConsumersNotAheadOfDelivery, 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, 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, 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 LastValueQueueImpl(Map<String,Object> attributes, VirtualHostImpl virtualHost)
protected void onOpen()
onOpen
in class AbstractQueue<LastValueQueueImpl>
public String getLvqKey()
getLvqKey
in interface LastValueQueue<LastValueQueueImpl>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.