public interface AkkaPduCodec
A Codec that is able to convert Akka PDUs (Protocol Data Units) from and to ByteString
s.
Modifier and Type | Interface and Description |
---|---|
static interface |
AkkaPduCodec.AkkaPdu
Trait that represents decoded Akka PDUs (Protocol Data Units)
|
static class |
AkkaPduCodec.Associate |
static class |
AkkaPduCodec.Associate$ |
static class |
AkkaPduCodec.Disassociate |
static class |
AkkaPduCodec.Disassociate$ |
static class |
AkkaPduCodec.Heartbeat$ |
static class |
AkkaPduCodec.Message |
static class |
AkkaPduCodec.Message$ |
static class |
AkkaPduCodec.Payload |
static class |
AkkaPduCodec.Payload$ |
Modifier and Type | Method and Description |
---|---|
akka.util.ByteString |
constructAssociate(HandshakeInfo info) |
akka.util.ByteString |
constructDisassociate(AssociationHandle.DisassociateInfo reason) |
akka.util.ByteString |
constructHeartbeat() |
akka.util.ByteString |
constructMessage(akka.actor.Address localAddress,
akka.actor.ActorRef recipient,
WireFormats.SerializedMessage serializedMessage,
scala.Option<akka.actor.ActorRef> senderOption,
scala.Option<SeqNo> seqOption,
scala.Option<Ack> ackOption) |
akka.util.ByteString |
constructPayload(akka.util.ByteString payload) |
akka.util.ByteString |
constructPureAck(Ack ack) |
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> |
decodeMessage(akka.util.ByteString raw,
RemoteActorRefProvider provider,
akka.actor.Address localAddress) |
AkkaPduCodec.AkkaPdu |
decodePdu(akka.util.ByteString raw)
Returns an
AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw
ByteString. |
akka.util.ByteString |
encodePdu(AkkaPduCodec.AkkaPdu pdu)
Takes an
AkkaPduCodec.AkkaPdu representation of an Akka PDU and returns its encoded
form as a ByteString . |
AkkaPduCodec.AkkaPdu decodePdu(akka.util.ByteString raw)
AkkaPduCodec.AkkaPdu
instance that represents the PDU contained in the raw
ByteString.raw
- Encoded raw byte representation of an Akka PDUakka.util.ByteString encodePdu(AkkaPduCodec.AkkaPdu pdu)
AkkaPduCodec.AkkaPdu
representation of an Akka PDU and returns its encoded
form as a ByteString
.
For the same effect the constructXXX methods might be called directly, taking method parameters instead of the
AkkaPduCodec.AkkaPdu
final case classes.
pdu
- The Akka Protocol Data Unit to be encodedakka.util.ByteString constructPayload(akka.util.ByteString payload)
akka.util.ByteString constructAssociate(HandshakeInfo info)
akka.util.ByteString constructDisassociate(AssociationHandle.DisassociateInfo reason)
akka.util.ByteString constructHeartbeat()
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(akka.util.ByteString raw, RemoteActorRefProvider provider, akka.actor.Address localAddress)
akka.util.ByteString constructMessage(akka.actor.Address localAddress, akka.actor.ActorRef recipient, WireFormats.SerializedMessage serializedMessage, scala.Option<akka.actor.ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
akka.util.ByteString constructPureAck(Ack ack)