public static final class Tcp.Register extends java.lang.Object implements Tcp.Command, scala.Product, scala.Serializable
Tcp.Connected
message. The connection will not read any data from the
socket until this message is received, because this message defines the
actor which will receive all inbound data.
param: handler The actor which will receive all incoming data and which will be informed when the connection is closed.
param: keepOpenOnPeerClosed If this is set to true then the connection
is not automatically closed when the peer closes its half,
requiring an explicit Tcp.CloseCommand
from our side when finished.
param: useResumeWriting If this is set to true then the connection actor
will refuse all further writes after issuing a Tcp.CommandFailed
notification until ResumeWriting
is received. This can
be used to implement NACK-based write backpressure.
Constructor and Description |
---|
Register(ActorRef handler,
boolean keepOpenOnPeerClosed,
boolean useResumeWriting) |
Modifier and Type | Method and Description |
---|---|
ActorRef |
handler() |
boolean |
keepOpenOnPeerClosed() |
boolean |
useResumeWriting() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
failureMessage