Package org.apache.pekko.remote.transport

Class PekkoPduProtobufCodec

java.lang.Object

org.apache.pekko.remote.transport.PekkoPduProtobufCodec

public class PekkoPduProtobufCodec
extends java.lang.Object

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
PekkoPduProtobufCodec()

Method Summary

Modifier and Type	Method	Description
static ByteString	constructAssociate(HandshakeInfo info)
static ByteString	constructDisassociate(AssociationHandle.DisassociateInfo info)
static ByteString	constructHeartbeat()
static ByteString	constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, <any> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
static scala.Option<SeqNo>	constructMessage$default$5()
static scala.Option<Ack>	constructMessage$default$6()
static ByteString	constructPayload(ByteString payload)
static ByteString	constructPureAck(Ack ack)
static scala.Tuple2<scala.Option<Ack>,scala.Option<PekkoPduCodec.Message>>	decodeMessage(ByteString raw, org.apache.pekko.remote.RemoteActorRefProvider provider, Address localAddress)
static PekkoPduCodec.PekkoPdu	decodePdu(ByteString raw)
static ByteString	encodePdu(PekkoPduCodec.PekkoPdu pdu)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PekkoPduProtobufCodec

public PekkoPduProtobufCodec()

Method Detail

constructMessage

public static ByteString constructMessage(Address localAddress,
                                          ActorRef recipient,
                                          WireFormats.SerializedMessage serializedMessage,
                                          <any> senderOption,
                                          scala.Option<SeqNo> seqOption,
                                          scala.Option<Ack> ackOption)

constructMessage$default$5

public static scala.Option<SeqNo> constructMessage$default$5()

constructMessage$default$6

public static scala.Option<Ack> constructMessage$default$6()

constructPureAck

public static ByteString constructPureAck(Ack ack)

constructPayload

public static ByteString constructPayload(ByteString payload)

constructAssociate

public static ByteString constructAssociate(HandshakeInfo info)

constructDisassociate

public static ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)

constructHeartbeat

public static ByteString constructHeartbeat()

decodePdu

public static PekkoPduCodec.PekkoPdu decodePdu(ByteString raw)

decodeMessage

public static scala.Tuple2<scala.Option<Ack>,scala.Option<PekkoPduCodec.Message>> decodeMessage(ByteString raw,
                                                                                                      org.apache.pekko.remote.RemoteActorRefProvider provider,
                                                                                                      Address localAddress)

encodePdu

public static ByteString encodePdu(PekkoPduCodec.PekkoPdu pdu)