org.osgi.util.pushstream

public Interface QueuePolicy<T, U extends BlockingQueue<PushEvent<? extends T>>>

Annotations

Type Parameters

Imports

A QueuePolicy is used to control how events should be queued in the current buffer. The QueuePolicy will be called when an event has arrived.

Method Summary

Modifier and Type	Method and Description
public void	doOffer(U queue, PushEvent<? extends T> event) Enqueue the event and return the remaining capacity available for events

doOffer back to summary

doOffer	back to summary
public void doOffer(U queue, PushEvent<? extends T> event) throws Exception Enqueue the event and return the remaining capacity available for events Exceptions Exception: If an error occurred adding the event to the queue. This exception will cause the connection between the `PushEventSource` and the `PushEventConsumer` to be closed with an `EventType#ERROR`

public void doOffer(U queue, PushEvent<? extends T> event) throws Exception

Enqueue the event and return the remaining capacity available for events

Exceptions

Exception:: If an error occurred adding the event to the queue. This exception will cause the connection between the PushEventSource and the PushEventConsumer to be closed with an EventType#ERROR