de.huxhorn.lilith

Class LilithBuffer<T extends java.io.Serializable>

java.lang.Object

de.huxhorn.sulky.buffers.BlockingCircularBuffer<EventWrapper<T>>

de.huxhorn.lilith.LilithBuffer<T>

All Implemented Interfaces:

de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T>>, de.huxhorn.sulky.buffers.Buffer<EventWrapper<T>>, de.huxhorn.sulky.buffers.CircularBuffer<EventWrapper<T>>, de.huxhorn.sulky.buffers.RemoveOperation<EventWrapper<T>>, de.huxhorn.sulky.buffers.ResetOperation, java.lang.Iterable<EventWrapper<T>>

public class LilithBuffer<T extends java.io.Serializable>
extends de.huxhorn.sulky.buffers.BlockingCircularBuffer<EventWrapper<T>>

Constructor Summary

Constructors

Constructor and Description
LilithBuffer(ApplicationPreferences applicationPreferences, int bufferSize)
LilithBuffer(ApplicationPreferences applicationPreferences, int bufferSize, int congestionDelay)

Method Summary

Modifier and Type	Method and Description
void	add(EventWrapper<T> element)
void	addAll(EventWrapper<T>[] elements)
void	addAll(java.util.List<EventWrapper<T>> elements)

Methods inherited from class de.huxhorn.sulky.buffers.BlockingCircularBuffer

clear, get, getAvailableElements, getBufferSize, getCongestionDelay, getOverflowCounter, getRelative, getSize, isEmpty, isFull, iterator, removeAll, removeFirst, reset, setCongestionDelay, setRelative

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

LilithBuffer

public LilithBuffer(ApplicationPreferences applicationPreferences,
                    int bufferSize,
                    int congestionDelay)

LilithBuffer

public LilithBuffer(ApplicationPreferences applicationPreferences,
                    int bufferSize)

Method Detail

add

public void add(EventWrapper<T> element)

Specified by:

add in interface de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T extends java.io.Serializable>>

Overrides:

add in class de.huxhorn.sulky.buffers.BlockingCircularBuffer<EventWrapper<T extends java.io.Serializable>>

addAll

public void addAll(java.util.List<EventWrapper<T>> elements)

Specified by:

addAll in interface de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T extends java.io.Serializable>>

Overrides:

addAll in class de.huxhorn.sulky.buffers.BlockingCircularBuffer<EventWrapper<T extends java.io.Serializable>>

addAll

public void addAll(EventWrapper<T>[] elements)

Specified by:

addAll in interface de.huxhorn.sulky.buffers.AppendOperation<EventWrapper<T extends java.io.Serializable>>

Overrides:

addAll in class de.huxhorn.sulky.buffers.BlockingCircularBuffer<EventWrapper<T extends java.io.Serializable>>