public class DefaultSerializedFireStage extends Object implements SerializedFireStage
SerializedFireStage
.
This implementation is based on an unbounded stage that enqueues the payload
objects to be fired (SerializedFireStage.enqueue(Object, SettableFuture)
) by
means of a LinkedBlockingQueue
.
Every instance of this class spans its dedicated stage thread, which sequentially
consumes payload objects off the stage queue.
Binary payloads are aggregated up to a maxBinaryPayloadAggregationSize
.
Constructor and Description |
---|
DefaultSerializedFireStage() |
DefaultSerializedFireStage(int maxBinaryPayloadAggregationSize) |
Modifier and Type | Method and Description |
---|---|
void |
enqueue(Object firePayload,
com.google.common.util.concurrent.SettableFuture<com.ning.http.client.Response> originalFuture) |
void |
fireSynchronously(org.atmosphere.wasync.serial.DefaultSerializedFireStage.FirePayloadEntry firePayloadEntry) |
void |
setSocket(SerializedSocket socket) |
void |
shutdown() |
public DefaultSerializedFireStage()
public DefaultSerializedFireStage(int maxBinaryPayloadAggregationSize)
public void setSocket(SerializedSocket socket)
setSocket
in interface SerializedFireStage
public void enqueue(Object firePayload, com.google.common.util.concurrent.SettableFuture<com.ning.http.client.Response> originalFuture)
enqueue
in interface SerializedFireStage
public void fireSynchronously(org.atmosphere.wasync.serial.DefaultSerializedFireStage.FirePayloadEntry firePayloadEntry)
public void shutdown()
shutdown
in interface SerializedFireStage
Copyright © 2015. All Rights Reserved.