Top Description Fields Constructors Methods

org.osgi.util.pushstream

public sealed Enum QueuePolicyOption

Class Inheritance

extends Enum<QueuePolicyOption>

java.lang.Object
java.lang.Enum
org.osgi.util.pushstream.QueuePolicyOption

Imports

java.util.concurrent.BlockingQueue

QueuePolicyOption provides a standard set of simple QueuePolicy implementations.

See Also: QueuePolicy

Field Summary

Modifier and Type	Field and Description
public static final QueuePolicyOption	BLOCK Attempt to add the supplied event to the queue, blocking until the enqueue is successful.
public static final QueuePolicyOption	DISCARD_OLDEST Attempt to add the supplied event to the queue.
public static final QueuePolicyOption	FAIL Attempt to add the supplied event to the queue, throwing an exception if the queue is full.

Constructor Summary

Access	Constructor and Description
private	QueuePolicyOption()

Method Summary

Modifier and Type	Method and Description
public abstract <T, U extends BlockingQueue<PushEvent<? extends T>>> QueuePolicy<T, U>	Returns: a `QueuePolicy` implementation getPolicy()
public static QueuePolicyOption	valueOf(String name)
public static QueuePolicyOption[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

BLOCK	back to summary
public static final QueuePolicyOption BLOCK Attempt to add the supplied event to the queue, blocking until the enqueue is successful.

DISCARD_OLDEST	back to summary
public static final QueuePolicyOption DISCARD_OLDEST Attempt to add the supplied event to the queue. If the queue is unable to immediately accept the value then discard the value at the head of the queue and try again. Repeat this process until the event is enqueued.

FAIL	back to summary
public static final QueuePolicyOption FAIL Attempt to add the supplied event to the queue, throwing an exception if the queue is full.

Constructor Detail

QueuePolicyOption	back to summary
private QueuePolicyOption()

Method Detail

getPolicy	back to summary
public abstract <T, U extends BlockingQueue<PushEvent<? extends T>>> QueuePolicy<T, U> getPolicy() Returns:QueuePolicy<T, U> a `QueuePolicy` implementation

valueOf	back to summary
public static QueuePolicyOption valueOf(String name)

values	back to summary
public static QueuePolicyOption[] values()