Package pl.tkowalcz.tjahzi

Class TimeCappedBatchingStrategy

java.lang.Object

pl.tkowalcz.tjahzi.TimeCappedBatchingStrategy

public class TimeCappedBatchingStrategy
extends Object

Constructor Summary

Constructors

Constructor	Description
TimeCappedBatchingStrategy(Clock clock, OutputBuffer outputBuffer, long batchSize, long batchWaitMillis, long shutdownTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
void	initShutdown()
boolean	shouldContinueShutdown()
boolean	shouldProceed()

Methods inherited from class java.lang.Object

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

Constructor Details

TimeCappedBatchingStrategy

public TimeCappedBatchingStrategy(Clock clock,
 OutputBuffer outputBuffer,
 long batchSize,
 long batchWaitMillis,
 long shutdownTimeoutMillis)

Method Details

shouldProceed

public boolean shouldProceed()

shouldContinueShutdown

public boolean shouldContinueShutdown()

initShutdown

public void initShutdown()