|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AkkaPduCodec
INTERNAL API
A Codec that is able to convert Akka PDUs (Protocol Data Units) from and to ByteString
s.
Nested Class Summary | |
---|---|
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$
|
Method Summary | |
---|---|
ByteString |
constructAssociate(HandshakeInfo info)
|
ByteString |
constructDisassociate(AssociationHandle.DisassociateInfo reason)
|
ByteString |
constructHeartbeat()
|
ByteString |
constructMessage(Address localAddress,
ActorRef recipient,
WireFormats.SerializedMessage serializedMessage,
scala.Option<ActorRef> senderOption,
scala.Option<SeqNo> seqOption,
scala.Option<Ack> ackOption)
|
ByteString |
constructPayload(ByteString payload)
|
ByteString |
constructPureAck(Ack ack)
|
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> |
decodeMessage(ByteString raw,
RemoteActorRefProvider provider,
Address localAddress)
|
AkkaPduCodec.AkkaPdu |
decodePdu(ByteString raw)
Returns an AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw
ByteString. |
ByteString |
encodePdu(AkkaPduCodec.AkkaPdu pdu)
Takes an AkkaPduCodec.AkkaPdu representation of an Akka PDU and returns its encoded
form as a ByteString . |
Method Detail |
---|
AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
AkkaPduCodec.AkkaPdu
instance that represents the PDU contained in the raw
ByteString.
raw
- Encoded raw byte representation of an Akka PDU
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
case classes.
pdu
- The Akka Protocol Data Unit to be encoded
ByteString constructPayload(ByteString payload)
ByteString constructAssociate(HandshakeInfo info)
ByteString constructDisassociate(AssociationHandle.DisassociateInfo reason)
ByteString constructHeartbeat()
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw, RemoteActorRefProvider provider, Address localAddress)
ByteString constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, scala.Option<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
ByteString constructPureAck(Ack ack)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |