com.birbit.android.jobqueue.messaging

Class SafeMessageQueue

java.lang.Object

com.birbit.android.jobqueue.messaging.SafeMessageQueue

All Implemented Interfaces:

MessageQueue

public class SafeMessageQueue
extends java.lang.Object
implements MessageQueue

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	logTag

Constructor Summary

Constructors

Constructor and Description
SafeMessageQueue(Timer timer, MessageFactory factory, java.lang.String logTag)

Method Summary

Modifier and Type	Method and Description
void	cancelMessages(MessagePredicate predicate)
void	clear()
void	consume(MessageQueueConsumer consumer)
boolean	isRunning()
void	post(Message message)
void	postAt(Message message, long readyNs)
void	postAtFront(Message message)
protected void	removeMessages(MessagePredicate predicate)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

logTag

public final java.lang.String logTag

Constructor Detail

SafeMessageQueue

public SafeMessageQueue(Timer timer,
                        MessageFactory factory,
                        java.lang.String logTag)

Method Detail

isRunning

public boolean isRunning()

consume

public void consume(MessageQueueConsumer consumer)

Specified by:

consume in interface MessageQueue

stop

public void stop()

Specified by:

stop in interface MessageQueue

clear

public void clear()

Specified by:

clear in interface MessageQueue

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

postAtFront

public void postAtFront(Message message)

removeMessages

protected void removeMessages(MessagePredicate predicate)