public interface MessageQueue
Modifier and Type | Method and Description |
---|---|
void |
cancelMessages(MessagePredicate predicate) |
void |
clear() |
void |
consume(MessageQueueConsumer consumer) |
void |
post(Message message) |
void |
postAt(Message message,
long readyNs) |
void |
stop() |
void post(Message message)
void postAt(Message message, long readyNs)
void cancelMessages(MessagePredicate predicate)
void stop()
void consume(MessageQueueConsumer consumer)
void clear()