akka.remote.transport
Interface AkkaPduCodec

All Known Implementing Classes:

AkkaPduProtobufCodec, AkkaPduProtobufCodec$

public interface AkkaPduCodec

INTERNAL API

A Codec that is able to convert Akka PDUs (Protocol Data Units) from and to ByteStrings.

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

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.

Method Detail

decodePdu

AkkaPduCodec.AkkaPdu decodePdu(akka.util.ByteString raw)

Returns an AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw ByteString.

Parameters:

raw - Encoded raw byte representation of an Akka PDU

Returns:

Case class representation of the decoded PDU that can be used in a match statement

encodePdu

akka.util.ByteString encodePdu(AkkaPduCodec.AkkaPdu pdu)

Takes an 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.

Parameters:

pdu - The Akka Protocol Data Unit to be encoded

Returns:

Encoded form as raw bytes

constructPayload

akka.util.ByteString constructPayload(akka.util.ByteString payload)

constructAssociate

akka.util.ByteString constructAssociate(HandshakeInfo info)

constructDisassociate

akka.util.ByteString constructDisassociate(AssociationHandle.DisassociateInfo reason)

constructHeartbeat

akka.util.ByteString constructHeartbeat()

decodeMessage

scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(akka.util.ByteString raw,
                                                                                 RemoteActorRefProvider provider,
                                                                                 akka.actor.Address localAddress)

constructMessage

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)

constructPureAck

akka.util.ByteString constructPureAck(Ack ack)