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

Interface ScheduledDeliveryHandler

All Known Implementing Classes:

ScheduledDeliveryHandlerImpl

public interface ScheduledDeliveryHandler

Method Summary

Modifier and Type	Method	Description
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()
MessageReference	peekFirstScheduledMessage()
MessageReference	removeReferenceWithID(long id)
MessageReference	removeReferenceWithID(long id, Transaction tx)

Method Details

checkAndSchedule

boolean checkAndSchedule(MessageReference ref,
 boolean tail)

getScheduledCount

int getScheduledCount()

getNonPagedScheduledCount

int getNonPagedScheduledCount()

getScheduledSize

long getScheduledSize()

getNonPagedScheduledSize

long getNonPagedScheduledSize()

getDurableScheduledCount

int getDurableScheduledCount()

getNonPagedDurableScheduledCount

int getNonPagedDurableScheduledCount()

getDurableScheduledSize

long getDurableScheduledSize()

getNonPagedDurableScheduledSize

long getNonPagedDurableScheduledSize()

peekFirstScheduledMessage

MessageReference peekFirstScheduledMessage()

getScheduledReferences

List<MessageReference> getScheduledReferences()

cancel

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

Throws:

ActiveMQException

removeReferenceWithID

MessageReference removeReferenceWithID(long id)
                                throws Exception

Throws:

Exception

removeReferenceWithID

MessageReference removeReferenceWithID(long id,
 Transaction tx)
                                throws Exception

Throws:

Exception