public class SerializedSocket extends AtmosphereSocket
SerializedSocket
is a Socket
implementation that guarantees ordered message delivery of
Socket.fire(Object)
calls, by serializing fire calls over a SerializedFireStage
.
SerializedSocket
guarantees to use only one underlying connection at any moment in time, while still
providing an asynchronous fire interface to clients.
Socket.STATUS
functions, options, request, socketRuntime, transportInUse
Constructor and Description |
---|
SerializedSocket(SerializedOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this Socket, asynchronously.
|
SocketRuntime |
createRuntime(DefaultFuture future,
Options options,
List<FunctionWrapper> functions) |
com.ning.http.client.ListenableFuture<com.ning.http.client.Response> |
directWrite(Object encodedPayload) |
SerializedFireStage |
getSerializedFireStage() |
addFunction, closeRuntime, doCloseRequest
connect, fire, getTransport, internalSocket, on, on, on, open, open, request, status
public SerializedSocket(SerializedOptions options)
public SocketRuntime createRuntime(DefaultFuture future, Options options, List<FunctionWrapper> functions)
createRuntime
in class AtmosphereSocket
public SerializedFireStage getSerializedFireStage()
public com.ning.http.client.ListenableFuture<com.ning.http.client.Response> directWrite(Object encodedPayload) throws IOException
IOException
public void close()
close
in interface Socket
close
in class AtmosphereSocket
Copyright © 2015. All Rights Reserved.