Package akka.remote.transport
Interface AkkaPduCodec
-
- All Known Implementing Classes:
AkkaPduProtobufCodec$
public interface AkkaPduCodec
Returns anAkkaPduCodec.AkkaPdu
instance that represents the PDU contained in the raw ByteString. param: raw Encoded raw byte representation of an Akka PDU
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
AkkaPduCodec.AkkaPdu
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
-
-
-
Method Detail
-
decodePdu
AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
Returns anAkkaPduCodec.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
ByteString encodePdu(AkkaPduCodec.AkkaPdu pdu)
Takes anAkkaPduCodec.AkkaPdu
representation of an Akka PDU and returns its encoded form as aByteString
.For the same effect the constructXXX methods might be called directly, taking method parameters instead of the
AkkaPduCodec.AkkaPdu
final case classes.- Parameters:
pdu
- The Akka Protocol Data Unit to be encoded- Returns:
- Encoded form as raw bytes
-
constructPayload
ByteString constructPayload(ByteString payload)
-
constructAssociate
ByteString constructAssociate(HandshakeInfo info)
-
constructDisassociate
ByteString constructDisassociate(AssociationHandle.DisassociateInfo reason)
-
constructHeartbeat
ByteString constructHeartbeat()
-
decodeMessage
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw, RemoteActorRefProvider provider, Address localAddress)
-
constructMessage
ByteString constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, OptionVal<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
-
constructMessage$default$5
scala.Option<SeqNo> constructMessage$default$5()
-
constructMessage$default$6
scala.Option<Ack> constructMessage$default$6()
-
constructPureAck
ByteString constructPureAck(Ack ack)
-
-