Class ScheduledDeliveryHandlerImpl
java.lang.Object
org.apache.activemq.artemis.core.server.impl.ScheduledDeliveryHandlerImpl
- All Implemented Interfaces:
ScheduledDeliveryHandler
Handles scheduling deliveries to a queue at the correct time.
-
Constructor Summary
ConstructorsConstructorDescriptionScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor, Queue queue) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddInPlace(long deliveryTime, MessageReference ref, boolean tail) cancel(Predicate<MessageReference> predicate) booleancheckAndSchedule(MessageReference ref, boolean tail) intlongintlongintlongintlongprotected voidremoveReferenceWithID(long id) removeReferenceWithID(long id, Transaction tx)
-
Constructor Details
-
ScheduledDeliveryHandlerImpl
-
-
Method Details
-
checkAndSchedule
- Specified by:
checkAndSchedulein interfaceScheduledDeliveryHandler
-
addInPlace
-
getScheduledCount
public int getScheduledCount()- Specified by:
getScheduledCountin interfaceScheduledDeliveryHandler
-
getNonPagedScheduledCount
public int getNonPagedScheduledCount()- Specified by:
getNonPagedScheduledCountin interfaceScheduledDeliveryHandler
-
getDurableScheduledCount
public int getDurableScheduledCount()- Specified by:
getDurableScheduledCountin interfaceScheduledDeliveryHandler
-
getNonPagedDurableScheduledCount
public int getNonPagedDurableScheduledCount()- Specified by:
getNonPagedDurableScheduledCountin interfaceScheduledDeliveryHandler
-
getScheduledSize
public long getScheduledSize()- Specified by:
getScheduledSizein interfaceScheduledDeliveryHandler
-
getNonPagedScheduledSize
public long getNonPagedScheduledSize()- Specified by:
getNonPagedScheduledSizein interfaceScheduledDeliveryHandler
-
getDurableScheduledSize
public long getDurableScheduledSize()- Specified by:
getDurableScheduledSizein interfaceScheduledDeliveryHandler
-
getNonPagedDurableScheduledSize
public long getNonPagedDurableScheduledSize()- Specified by:
getNonPagedDurableScheduledSizein interfaceScheduledDeliveryHandler
-
getScheduledReferences
- Specified by:
getScheduledReferencesin interfaceScheduledDeliveryHandler
-
cancel
public List<MessageReference> cancel(Predicate<MessageReference> predicate) throws ActiveMQException - Specified by:
cancelin interfaceScheduledDeliveryHandler- Throws:
ActiveMQException
-
removeReferenceWithID
- Specified by:
removeReferenceWithIDin interfaceScheduledDeliveryHandler- Throws:
Exception
-
removeReferenceWithID
- Specified by:
removeReferenceWithIDin interfaceScheduledDeliveryHandler- Throws:
Exception
-
notifyScheduledReferencesUpdated
protected void notifyScheduledReferencesUpdated() -
peekFirstScheduledMessage
- Specified by:
peekFirstScheduledMessagein interfaceScheduledDeliveryHandler
-