org.axonframework.kafka.eventhandling.consumer

Interface Buffer<E>

Type Parameters:

E -

All Known Implementing Classes:

SortedKafkaMessageBuffer

public interface Buffer<E>

Defines a buffer that wait for the space to become non-empty when retrieving an element, and wait for space to become available in the buffer when storing an element.

Author:

Nakul Mishra

Method Summary

Modifier and Type	Method and Description
void	clear()
boolean	isEmpty()
E	peek()
E	poll(long timeout, TimeUnit unit)
void	put(E e)
void	putAll(Collection<E> c)
int	remainingCapacity()
int	size()
E	take()

Method Detail

put

void put(E e)
  throws InterruptedException

Throws:

InterruptedException

putAll

void putAll(Collection<E> c)
     throws InterruptedException

Throws:

InterruptedException

poll

E poll(long timeout,
       TimeUnit unit)
throws InterruptedException

Throws:

InterruptedException

take

E take()
throws InterruptedException

Throws:

InterruptedException

peek

E peek()

size

int size()

isEmpty

boolean isEmpty()

remainingCapacity

int remainingCapacity()

clear

void clear()