org.agilewiki.jactor.bufferedEvents

Interface BufferedEventsQueue<E>

Type Parameters:

E - The type of event.

All Superinterfaces:

BufferedEventsDestination<E>, EventDispatcher<E>

All Known Implementing Classes:

JABufferedEventsQueue

public interface BufferedEventsQueue<E>
extends BufferedEventsDestination<E>, EventDispatcher<E>

A BufferedEventsQueue receives buffered events, queues them, and then processes them on another thread.

Method Summary

Methods

Modifier and Type	Method and Description
EventQueue<ArrayList<E>>	getEventQueue() Returns the event queue.
void	send(BufferedEventsDestination<E> destination, E event) Buffer the event for subsequent sending.
void	sendPendingEvents() Send any pending events.
void	setInitialBufferCapacity(int initialBufferCapacity) Set the initial capacity for buffered outgoing events.

Methods inherited from interface org.agilewiki.jactor.bufferedEvents.BufferedEventsDestination

putBufferedEvents

Methods inherited from interface org.agilewiki.jactor.events.EventDispatcher

dispatchEvents, isEmpty, setActiveEventProcessor

Method Detail

sendPendingEvents

void sendPendingEvents()

Send any pending events.

setInitialBufferCapacity

void setInitialBufferCapacity(int initialBufferCapacity)

Set the initial capacity for buffered outgoing events.

Parameters:

initialBufferCapacity - The initial capacity for buffered outgoing events.

send

void send(BufferedEventsDestination<E> destination,
        E event)

Buffer the event for subsequent sending.

Parameters:

destination - Buffered events receiver.

event - The event to be sent.

getEventQueue

EventQueue<ArrayList<E>> getEventQueue()

Returns the event queue.

Returns:

The event queue.