org.hornetq.core.server.impl

Class ScheduledDeliveryHandlerImpl

java.lang.Object

org.hornetq.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.

Author:

Tim Fox, Andy Taylor, Jeff Mesnil, Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
List<MessageReference>	cancel(Filter filter)
boolean	checkAndSchedule(MessageReference ref, boolean tail)
int	getScheduledCount()
List<MessageReference>	getScheduledReferences()
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)

Method Detail

checkAndSchedule

public boolean checkAndSchedule(MessageReference ref,
                       boolean tail)

Specified by:

checkAndSchedule in interface ScheduledDeliveryHandler

getScheduledCount

public int getScheduledCount()

Specified by:

getScheduledCount in interface ScheduledDeliveryHandler

getScheduledReferences

public List<MessageReference> getScheduledReferences()

Specified by:

getScheduledReferences in interface ScheduledDeliveryHandler

cancel

public List<MessageReference> cancel(Filter filter)

Specified by:

cancel in interface ScheduledDeliveryHandler

removeReferenceWithID

public MessageReference removeReferenceWithID(long id)

Specified by:

removeReferenceWithID in interface ScheduledDeliveryHandler