public class ScheduledDeliveryHandlerImpl extends Object implements ScheduledDeliveryHandler
Constructor and Description |
---|
ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor) |
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 |
getScheduledCount() |
List<MessageReference> |
getScheduledReferences() |
MessageReference |
removeReferenceWithID(long id) |
public ScheduledDeliveryHandlerImpl(ScheduledExecutorService scheduledExecutor)
public boolean checkAndSchedule(MessageReference ref, boolean tail)
checkAndSchedule
in interface ScheduledDeliveryHandler
public void addInPlace(long deliveryTime, MessageReference ref, boolean tail)
public int getScheduledCount()
getScheduledCount
in interface ScheduledDeliveryHandler
public List<MessageReference> getScheduledReferences()
getScheduledReferences
in interface ScheduledDeliveryHandler
public List<MessageReference> cancel(Filter filter) throws ActiveMQException
cancel
in interface ScheduledDeliveryHandler
ActiveMQException
public MessageReference removeReferenceWithID(long id) throws ActiveMQException
removeReferenceWithID
in interface ScheduledDeliveryHandler
ActiveMQException
Copyright © 2016 The Apache Software Foundation. All rights reserved.