org.hornetq.core.server.impl

Class LastValueQueue

java.lang.Object

org.hornetq.core.server.impl.QueueImpl

org.hornetq.core.server.impl.LastValueQueue

All Implemented Interfaces:

Bindable, Queue

public class LastValueQueue
extends QueueImpl

A queue that will discard messages if a newer message with the same MessageImpl.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

Author:

Andy Taylor, Tim Fox rewrite

Field Summary

Fields inherited from class org.hornetq.core.server.impl.QueueImpl

CHECK_QUEUE_SIZE_PERIOD, deliveringCount, MAX_DELIVERIES_IN_LOOP, NUM_PRIORITIES, REDISTRIBUTOR_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
LastValueQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, boolean durable, boolean temporary, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, Executor executor)

Method Summary

Methods

Modifier and Type	Method and Description
void	addHead(MessageReference ref)
void	addTail(MessageReference ref, boolean direct)

Methods inherited from class org.hornetq.core.server.impl.QueueImpl

acknowledge, acknowledge, addConsumer, addRedistributor, addTail, cancel, cancel, cancelRedistributor, changeReferencePriority, changeReferencesPriority, checkRedelivery, close, debug, deleteAllReferences, deleteMatchingReferences, deleteReference, deliverAsync, deliverNow, equals, expire, expireReference, expireReferences, expireReferences, finalize, flushExecutor, forceDelivery, getAddress, getConsumerCount, getConsumers, getDeliveringCount, getExecutor, getFilter, getID, getInstantMessageCount, getInstantMessagesAdded, getMessageCount, getMessagesAdded, getName, getNumberOfReferences, getPageSubscription, getReference, getRoutingName, getScheduledCount, getScheduledMessages, getUniqueName, hashCode, hasMatchingConsumer, isDirectDeliver, isDurable, isExclusive, isInternalQueue, isPaused, isTemporary, iterator, moveReference, moveReference, moveReferences, moveReferences, pause, postAcknowledge, reacknowledge, refAdded, referenceHandled, reload, removeConsumer, removeReferenceWithID, resetAllIterators, resume, route, sendMessagesToDeadLetterAddress, sendMessageToDeadLetterAddress, setExpiryAddress, setInternalQueue, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LastValueQueue

public LastValueQueue(long persistenceID,
              SimpleString address,
              SimpleString name,
              Filter filter,
              PageSubscription pageSubscription,
              boolean durable,
              boolean temporary,
              ScheduledExecutorService scheduledExecutor,
              PostOffice postOffice,
              StorageManager storageManager,
              HierarchicalRepository<AddressSettings> addressSettingsRepository,
              Executor executor)

Method Detail

addTail

public void addTail(MessageReference ref,
           boolean direct)

Specified by:

addTail in interface Queue

Overrides:

addTail in class QueueImpl

addHead

public void addHead(MessageReference ref)

Specified by:

addHead in interface Queue

Overrides:

addHead in class QueueImpl