Package com.avoka.fc.core.outbox

Class OutboxThread

java.lang.Object

com.avoka.fc.core.outbox.OutboxThread

All Implemented Interfaces:

Runnable

public class OutboxThread
extends Object
implements Runnable

Provides an OutboxThread to pull events from queue send to OutboxProcessor to process. This class follows the Producer/Consumer design pattern.

Since:

22.10.0

Method Summary

Modifier and Type	Method	Description
static BlockingQueue<Long>	getQueueAndStart()	Return the Blocking Queue.If the thread is not running, it starts to run
static Boolean	isRunning()
void	run()	consume the outbox queue and process

Methods inherited from class java.lang.Object

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

Method Details

getQueueAndStart

public static BlockingQueue<Long> getQueueAndStart()

Return the Blocking Queue.If the thread is not running, it starts to run

Returns:

the Blocking Queue

isRunning

public static Boolean isRunning()

run

public void run()

consume the outbox queue and process

Specified by:

run in interface Runnable