Package com.illumon.iris.db.v2.logaggregator

Class SinkHandle

java.lang.Object

com.illumon.iris.db.v2.logaggregator.SinkHandle

public class SinkHandle
extends Object

Handle for a BinaryLogQueueSink. Allows the output sink to be replaced out from under the consumer. Class instances are expected to be used from a single thread.

Method Summary

Modifier and Type	Method	Description
void	put(CommandHelper.LogAggregatorMessage m)	Add a message to the associated queue.

Methods inherited from class java.lang.Object

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

Method Details

put

public void put(CommandHelper.LogAggregatorMessage m) throws InterruptedException

Add a message to the associated queue.

Parameters:

m - The message to add

Throws:

InterruptedException