rsb.util

Class QueueAdapter<T>

java.lang.Object

rsb.AbstractDataHandler<T>

rsb.util.QueueAdapter<T>

All Implemented Interfaces:

java.util.EventListener, Handler

public class QueueAdapter<T>
extends AbstractDataHandler<T>

Synchronized queue implementing the rsb.DataHandler interface. Can be directly registered as handler in rsb.Listener instance and used for receiving and storing dispatched events.

Author:

swrede, dklotz

Constructor Summary

Constructors

Constructor and Description
QueueAdapter() Creates an adapter with a preset unlimited queue inside.
QueueAdapter(java.util.concurrent.BlockingQueue<T> queue)
QueueAdapter(int capacity, boolean discardOldest) Creates an adapter with a preset queue inside that is limited to capacity elements.

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.BlockingQueue<T>	getQueue()
void	handleEvent(T data)

Methods inherited from class rsb.AbstractDataHandler

internalNotify

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueAdapter

public QueueAdapter()

Creates an adapter with a preset unlimited queue inside.

QueueAdapter

public QueueAdapter(int capacity,
            boolean discardOldest)

Creates an adapter with a preset queue inside that is limited to capacity elements.

Parameters:

capacity - capacity of the internal queue

QueueAdapter

public QueueAdapter(java.util.concurrent.BlockingQueue<T> queue)

Method Detail

handleEvent

public void handleEvent(T data)

Specified by:

handleEvent in class AbstractDataHandler<T>

getQueue

public java.util.concurrent.BlockingQueue<T> getQueue()