Package org.osgi.util.pushstream

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

Type Parameters:

T - The type of the data

U - The type of the queue

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@ConsumerType
@FunctionalInterface
public interface QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>

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.

See Also:

• QueuePolicyOption

Method Summary

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

Method Details

doOffer

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

Enqueue the event and return the remaining capacity available for events

Parameters:

queue -

event -

Throws:

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 PushEvent.EventType.ERROR