com.birbit.android.jobqueue.messaging

Class PriorityMessageQueue

java.lang.Object

com.birbit.android.jobqueue.messaging.PriorityMessageQueue

All Implemented Interfaces:

MessageQueue

public class PriorityMessageQueue
extends java.lang.Object
implements MessageQueue

Uses multiple message queues to simulate priority.

Constructor Summary

Constructors

Constructor and Description
PriorityMessageQueue(Timer timer, MessageFactory factory)

Method Summary

Modifier and Type	Method and Description
void	cancelMessages(MessagePredicate predicate)
void	clear()
void	consume(MessageQueueConsumer consumer)
Message	next(MessageQueueConsumer consumer)
void	post(Message message)
void	postAt(Message message, long readyNs)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PriorityMessageQueue

public PriorityMessageQueue(Timer timer,
                            MessageFactory factory)

Method Detail

consume

public void consume(MessageQueueConsumer consumer)

Specified by:

consume in interface MessageQueue

clear

public void clear()

Specified by:

clear in interface MessageQueue

stop

public void stop()

Specified by:

stop in interface MessageQueue

next

public Message next(MessageQueueConsumer consumer)

post

public void post(Message message)

Specified by:

post in interface MessageQueue

postAt

public void postAt(Message message,
                   long readyNs)

Specified by:

postAt in interface MessageQueue

cancelMessages

public void cancelMessages(MessagePredicate predicate)

Specified by:

cancelMessages in interface MessageQueue