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

Class ScheduledDeliveryHandlerImpl

java.lang.Object

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

All Implemented Interfaces:

ScheduledDeliveryHandler

public class ScheduledDeliveryHandlerImpl
extends Object
implements ScheduledDeliveryHandler

Handles scheduling deliveries to a queue at the correct time.

Constructor Summary

Constructors

Constructor	Description
ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor, Queue queue)

Method Summary

Modifier and Type	Method	Description
void	addInPlace(long deliveryTime, MessageReference ref, boolean tail)
List<MessageReference>	cancel(Predicate<MessageReference> predicate)
boolean	checkAndSchedule(MessageReference ref, boolean tail)
int	getDurableScheduledCount()
long	getDurableScheduledSize()
int	getNonPagedDurableScheduledCount()
long	getNonPagedDurableScheduledSize()
int	getNonPagedScheduledCount()
long	getNonPagedScheduledSize()
int	getScheduledCount()
List<MessageReference>	getScheduledReferences()
long	getScheduledSize()
protected void	notifyScheduledReferencesUpdated()
MessageReference	peekFirstScheduledMessage()
MessageReference	removeReferenceWithID(long id)
MessageReference	removeReferenceWithID(long id, Transaction tx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ScheduledDeliveryHandlerImpl

public ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor,
 Queue queue)

Method Details

checkAndSchedule

public boolean checkAndSchedule(MessageReference ref,
 boolean tail)

Specified by:

checkAndSchedule in interface ScheduledDeliveryHandler

addInPlace

public void addInPlace(long deliveryTime,
 MessageReference ref,
 boolean tail)

getScheduledCount

public int getScheduledCount()

Specified by:

getScheduledCount in interface ScheduledDeliveryHandler

getNonPagedScheduledCount

public int getNonPagedScheduledCount()

Specified by:

getNonPagedScheduledCount in interface ScheduledDeliveryHandler

getDurableScheduledCount

public int getDurableScheduledCount()

Specified by:

getDurableScheduledCount in interface ScheduledDeliveryHandler

getNonPagedDurableScheduledCount

public int getNonPagedDurableScheduledCount()

Specified by:

getNonPagedDurableScheduledCount in interface ScheduledDeliveryHandler

getScheduledSize

public long getScheduledSize()

Specified by:

getScheduledSize in interface ScheduledDeliveryHandler

getNonPagedScheduledSize

public long getNonPagedScheduledSize()

Specified by:

getNonPagedScheduledSize in interface ScheduledDeliveryHandler

getDurableScheduledSize

public long getDurableScheduledSize()

Specified by:

getDurableScheduledSize in interface ScheduledDeliveryHandler

getNonPagedDurableScheduledSize

public long getNonPagedDurableScheduledSize()

Specified by:

getNonPagedDurableScheduledSize in interface ScheduledDeliveryHandler

getScheduledReferences

public List<MessageReference> getScheduledReferences()

Specified by:

getScheduledReferences in interface ScheduledDeliveryHandler

cancel

public List<MessageReference> cancel(Predicate<MessageReference> predicate)
                              throws ActiveMQException

Specified by:

cancel in interface ScheduledDeliveryHandler

Throws:

ActiveMQException

removeReferenceWithID

public MessageReference removeReferenceWithID(long id)
                                       throws Exception

Specified by:

removeReferenceWithID in interface ScheduledDeliveryHandler

Throws:

Exception

removeReferenceWithID

public MessageReference removeReferenceWithID(long id,
 Transaction tx)
                                       throws Exception

Specified by:

removeReferenceWithID in interface ScheduledDeliveryHandler

Throws:

Exception

notifyScheduledReferencesUpdated

protected void notifyScheduledReferencesUpdated()

peekFirstScheduledMessage

public MessageReference peekFirstScheduledMessage()

Specified by:

peekFirstScheduledMessage in interface ScheduledDeliveryHandler