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.