PekkoPduProtobufCodec

java.lang.Object

org.apache.pekko.remote.transport.PekkoPduProtobufCodec

public class PekkoPduProtobufCodec extends 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 Details
- PekkoPduProtobufCodec
  
  public PekkoPduProtobufCodec()
Method Details
- 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)