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

Class BinaryLogQueueSink

java.lang.Object

com.illumon.iris.db.v2.logaggregator.BinaryLogQueueSink

All Implemented Interfaces:

Runnable

public class BinaryLogQueueSink
extends Object
implements Runnable

Drain a binary log queue (to files).

Method Summary

Modifier and Type	Method	Description
void	put(CommandHelper.LogAggregatorMessage message)
void	run()
Thread	start()	Helper method to start and grant access to the execution thread for this sink.
CommandHelper.LogAggregatorMessage	take()
Thread.State	threadState()

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 message)
         throws InterruptedException

Throws:

InterruptedException

take

public CommandHelper.LogAggregatorMessage take()
                                        throws InterruptedException

Throws:

InterruptedException

run

public void run()

Specified by:

run in interface Runnable

start

public Thread start()

Helper method to start and grant access to the execution thread for this sink. Starting the thread needs to be separated from the construction of the object. It is invalid to start a thread twice.

threadState

public Thread.State threadState()

Returns:

the state of the execution thread.