org.apache.activemq.artemis.core.server.impl

Class LastValueQueue

java.lang.Object

org.apache.activemq.artemis.utils.critical.CriticalComponentImpl

org.apache.activemq.artemis.core.server.impl.QueueImpl

org.apache.activemq.artemis.core.server.impl.LastValueQueue

All Implemented Interfaces:

Bindable, Queue, CriticalComponent

public class LastValueQueue
extends QueueImpl

A queue that will discard messages if a newer message with the same Message.HDR_LAST_VALUE_NAME property value. In other words it only retains the last value

This is useful for example, for stock prices, where you're only interested in the latest value for a particular stock

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.server.impl.QueueImpl

QueueImpl.ConsumerHolder<T extends Consumer>

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedList<MessageReference>	nextDeliveries

Fields inherited from class org.apache.activemq.artemis.core.server.impl.QueueImpl

CHECK_QUEUE_SIZE_PERIOD, CRITICAL_CHECK_DEPAGE, CRITICAL_CONSUMER, CRITICAL_DELIVER, CRITICAL_PATH_ADD_HEAD, CRITICAL_PATH_ADD_TAIL, CRITICAL_PATHS, DEFAULT_FLUSH_LIMIT, DELIVERY_TIMEOUT, dispatching, dispatchStartTime, MAX_DELIVERIES_IN_LOOP, NUM_PRIORITIES, pageSubscription, pendingMetrics, REDISTRIBUTOR_BATCH_SIZE, scheduledDeliveryHandler

Fields inherited from interface org.apache.activemq.artemis.core.server.Queue

MAX_CONSUMERS_UNLIMITED

Constructor Summary

Constructors

Constructor and Description
LastValueQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean purgeOnNoConsumers, SimpleString lastValueKey, Boolean nonDestructive, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean configurationManaged, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) Deprecated.
LastValueQueue(QueueConfiguration queueConfiguration, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)
void	addHead(MessageReference ref, boolean scheduling)
void	addTail(MessageReference ref, boolean direct)
boolean	allowsReferenceCallback() the current queue and consumer settings will allow use of the Reference Execution and callback.
boolean	equals(Object obj)
SimpleString	getLastValueKey()
Set<SimpleString>	getLastValueKeys()
long	getMessageCount()
QueueConfiguration	getQueueConfiguration()
int	hashCode()
boolean	isLastValue()
protected MessageReference	nextDelivery()
void	postAcknowledge(MessageReference ref, AckReason reason)
protected void	refRemoved(MessageReference ref)
void	reload(MessageReference ref)
protected void	repeatNextDelivery(MessageReference reference)

Methods inherited from class org.apache.activemq.artemis.core.server.impl.QueueImpl

acknowledge, acknowledge, acknowledge, addConsumer, addHead, addLingerSession, addRedistributor, addRefSize, addSorted, addSorted, addTail, browserIterator, cancel, cancel, cancel, cancelRedistributor, changeReferencePriority, changeReferencesPriority, checkRedelivery, close, debug, decDelivering, deleteAllReferences, deleteAllReferences, deleteMatchingReferences, deleteMatchingReferences, deleteQueue, deleteQueue, deleteReference, deliverAsync, deliverNow, deliverScheduledMessages, destroyPaging, durableDown, durableUp, errorProcessing, expire, expire, expireReference, expireReferences, expireReferences, finalize, flushExecutor, forceDelivery, getAcknowledgeAttempts, getAddress, getAutoDeleteDelay, getAutoDeleteMessageCount, getConsumerCount, getConsumerRemovedTimestamp, getConsumers, getConsumersBeforeDispatch, getConsumersRefCount, getDelayBeforeDispatch, getDeliveringCount, getDeliveringMessages, getDeliveringSize, getDispatchStartTime, getDurableDeliveringCount, getDurableDeliveringSize, getDurableMessageCount, getDurablePersistentSize, getDurableScheduledCount, getDurableScheduledSize, getExecutor, getExpiryAddress, getFilter, getGroupBuckets, getGroupCount, getGroupFirstKey, getGroups, getID, getMaxConsumers, getMessageCountForRing, getMessagesAcknowledged, getMessagesAdded, getMessagesExpired, getMessagesKilled, getMessagesReplaced, getName, getNumberOfReferences, getPageSubscription, getPagingStore, getPersistentSize, getRate, getReference, getRingSize, getRoutingName, getRoutingType, getScheduledCount, getScheduledMessages, getScheduledSize, getUniqueName, getUser, groupMap, hasMatchingConsumer, incrementMesssagesAdded, isAutoCreated, isAutoDelete, isConfigurationManaged, isDirectDeliver, isDispatching, isDurable, isDurableMessage, isEnabled, isExclusive, isExpirationRedundant, isGroupRebalance, isGroupRebalancePauseDispatch, isInternalQueue, isMirrorController, isNonDestructive, isPaused, isPersistedPause, isPurgeOnNoConsumers, isSwept, isTemporary, iterator, moveReference, moveReferences, moveReferences, moveReferencesBetweenSnFQueues, pause, pause, reacknowledge, recheckRefCount, refAdded, refDown, referenceHandled, refUp, reloadPause, removeAddress, removeConsumer, removeLingerSession, removeMessageReference, removeReferenceWithID, removeWithSuppliedID, rerouteMessages, resetAllGroups, resetAllIterators, resetGroup, resetMessagesAcknowledged, resetMessagesAdded, resetMessagesExpired, resetMessagesKilled, resume, retryMessages, retryMessages, route, routeWithAck, scheduleIfPossible, sendMessagesToDeadLetterAddress, sendMessageToDeadLetterAddress, sendToDeadLetterAddress, setConfigurationManaged, setConsumersBeforeDispatch, setConsumersRefCount, setDelayBeforeDispatch, setDispatching, setEnabled, setExclusive, setFilter, setGroupBuckets, setGroupFirstKey, setGroupRebalance, setGroupRebalancePauseDispatch, setInternalQueue, setMaxConsumer, setMirrorController, setNonDestructive, setPurgeOnNoConsumers, setRingSize, setRoutingType, setSwept, setUser, toString, unproposed

Methods inherited from class org.apache.activemq.artemis.utils.critical.CriticalComponentImpl

checkExpiration, getCriticalAnalyzer, measureCritical

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.Queue

deleteMatchingReferences, expireReferences

Methods inherited from interface org.apache.activemq.artemis.utils.critical.CriticalComponent

checkExpiration, getCriticalAnalyzer, measureCritical

Field Detail

nextDeliveries

protected final LinkedList<MessageReference> nextDeliveries

Constructor Detail

LastValueQueue

@Deprecated
public LastValueQueue(long persistenceID,
                                  SimpleString address,
                                  SimpleString name,
                                  Filter filter,
                                  PagingStore pagingStore,
                                  PageSubscription pageSubscription,
                                  SimpleString user,
                                  boolean durable,
                                  boolean temporary,
                                  boolean autoCreated,
                                  RoutingType routingType,
                                  Integer maxConsumers,
                                  Boolean exclusive,
                                  Boolean groupRebalance,
                                  Integer groupBuckets,
                                  SimpleString groupFirstKey,
                                  Integer consumersBeforeDispatch,
                                  Long delayBeforeDispatch,
                                  Boolean purgeOnNoConsumers,
                                  SimpleString lastValueKey,
                                  Boolean nonDestructive,
                                  Boolean autoDelete,
                                  Long autoDeleteDelay,
                                  Long autoDeleteMessageCount,
                                  boolean configurationManaged,
                                  ScheduledExecutorService scheduledExecutor,
                                  PostOffice postOffice,
                                  StorageManager storageManager,
                                  HierarchicalRepository<AddressSettings> addressSettingsRepository,
                                  ArtemisExecutor executor,
                                  ActiveMQServer server,
                                  QueueFactory factory)

Deprecated.

LastValueQueue

public LastValueQueue(QueueConfiguration queueConfiguration,
                      PagingStore pagingStore,
                      PageSubscription pageSubscription,
                      ScheduledExecutorService scheduledExecutor,
                      PostOffice postOffice,
                      StorageManager storageManager,
                      HierarchicalRepository<AddressSettings> addressSettingsRepository,
                      ArtemisExecutor executor,
                      ActiveMQServer server,
                      QueueFactory factory)

Method Detail

nextDelivery

protected MessageReference nextDelivery()

Overrides:

nextDelivery in class QueueImpl

repeatNextDelivery

protected void repeatNextDelivery(MessageReference reference)

Overrides:

repeatNextDelivery in class QueueImpl

addTail

public void addTail(MessageReference ref,
                    boolean direct)

Specified by:

addTail in interface Queue

Overrides:

addTail in class QueueImpl

getMessageCount

public long getMessageCount()

Specified by:

getMessageCount in interface Queue

Overrides:

getMessageCount in class QueueImpl

addHead

public void addHead(MessageReference ref,
                    boolean scheduling)

Specified by:

addHead in interface Queue

Overrides:

addHead in class QueueImpl

postAcknowledge

public void postAcknowledge(MessageReference ref,
                            AckReason reason)

Specified by:

postAcknowledge in interface Queue

Overrides:

postAcknowledge in class QueueImpl

allowsReferenceCallback

public boolean allowsReferenceCallback()

Description copied from interface: Queue

the current queue and consumer settings will allow use of the Reference Execution and callback. This is because

Specified by:

allowsReferenceCallback in interface Queue

Overrides:

allowsReferenceCallback in class QueueImpl

getQueueConfiguration

public QueueConfiguration getQueueConfiguration()

Specified by:

getQueueConfiguration in interface Queue

Overrides:

getQueueConfiguration in class QueueImpl

refRemoved

protected void refRemoved(MessageReference ref)

Overrides:

refRemoved in class QueueImpl

acknowledge

public void acknowledge(MessageReference ref,
                        AckReason reason,
                        ServerConsumer consumer)
                 throws Exception

Specified by:

acknowledge in interface Queue

Overrides:

acknowledge in class QueueImpl

Throws:

Exception

acknowledge

public void acknowledge(Transaction tx,
                        MessageReference ref,
                        AckReason reason,
                        ServerConsumer consumer)
                 throws Exception

Specified by:

acknowledge in interface Queue

Overrides:

acknowledge in class QueueImpl

Throws:

Exception

reload

public void reload(MessageReference ref)

Specified by:

reload in interface Queue

Overrides:

reload in class QueueImpl

isLastValue

public boolean isLastValue()

Specified by:

isLastValue in interface Queue

Overrides:

isLastValue in class QueueImpl

getLastValueKey

public SimpleString getLastValueKey()

Specified by:

getLastValueKey in interface Queue

Overrides:

getLastValueKey in class QueueImpl

getLastValueKeys

public Set<SimpleString> getLastValueKeys()

hashCode

public int hashCode()

Overrides:

hashCode in class QueueImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class QueueImpl