com.metamx.tranquility.tranquilizer.Tranquilizer
Whether "send" will block (true) or throw an exception (false) when called while the outgoing queue is full.
Whether "send" will block (true) or throw an exception (false) when called while the outgoing queue is full. Optional, default is true.
flag for blocking when full
new builder
Build a Tranquilizer.
Build a Tranquilizer.
beam to wrap
tranquilizer
Wait this long for batches to collect more messages (up to maxBatchSize) before sending them.
Wait this long for batches to collect more messages (up to maxBatchSize) before sending them. Set to zero to disable waiting. Optional, default is zero.
linger millis
new builder
Maximum number of messages to send at once.
Maximum number of messages to send at once. Optional, default is 5000.
max batch size
new builder
Maximum number of batches that may be in flight before we block and wait for one to finish.
Maximum number of batches that may be in flight before we block and wait for one to finish. Optional, default is 5.
max pending batches
new builder