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 and Description
ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor, Queue queue)

Method Summary

Modifier and Type	Method and Description
void	addInPlace(long deliveryTime, MessageReference ref, boolean tail)
List<MessageReference>	cancel(Filter filter)
boolean	checkAndSchedule(MessageReference ref, boolean tail)
int	getDurableScheduledCount()
long	getDurableScheduledSize()
int	getScheduledCount()
List<MessageReference>	getScheduledReferences()
long	getScheduledSize()
MessageReference	removeReferenceWithID(long id)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledDeliveryHandlerImpl

public ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor,
                                    Queue queue)

Method Detail

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

getDurableScheduledCount

public int getDurableScheduledCount()

Specified by:

getDurableScheduledCount in interface ScheduledDeliveryHandler

getScheduledSize

public long getScheduledSize()

Specified by:

getScheduledSize in interface ScheduledDeliveryHandler

getDurableScheduledSize

public long getDurableScheduledSize()

Specified by:

getDurableScheduledSize in interface ScheduledDeliveryHandler

getScheduledReferences

public List<MessageReference> getScheduledReferences()

Specified by:

getScheduledReferences in interface ScheduledDeliveryHandler

cancel

public List<MessageReference> cancel(Filter filter)
                              throws ActiveMQException

Specified by:

cancel in interface ScheduledDeliveryHandler

Throws:

ActiveMQException

removeReferenceWithID

public MessageReference removeReferenceWithID(long id)
                                       throws ActiveMQException

Specified by:

removeReferenceWithID in interface ScheduledDeliveryHandler

Throws:

ActiveMQException