Package org.apache.pekko.remote.transport

Class PekkoPduProtobufCodec$

java.lang.Object

org.apache.pekko.remote.transport.PekkoPduProtobufCodec$

All Implemented Interfaces:

PekkoPduCodec

public class PekkoPduProtobufCodec$
extends java.lang.Object
implements PekkoPduCodec

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.remote.transport.PekkoPduCodec

PekkoPduCodec.Associate, PekkoPduCodec.Associate$, PekkoPduCodec.Disassociate, PekkoPduCodec.Disassociate$, PekkoPduCodec.Heartbeat$, PekkoPduCodec.Message, PekkoPduCodec.Message$, PekkoPduCodec.Payload, PekkoPduCodec.Payload$, PekkoPduCodec.PekkoPdu

Field Summary

Fields

Modifier and Type	Field	Description
static PekkoPduProtobufCodec$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
PekkoPduProtobufCodec$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.remote.transport.PekkoPduCodec

encodePdu

Field Detail

MODULE$

public static final PekkoPduProtobufCodec$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PekkoPduProtobufCodec$

public PekkoPduProtobufCodec$()

Method Detail

constructMessage

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

Specified by:

constructMessage in interface PekkoPduCodec

constructMessage$default$5

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

Specified by:

constructMessage$default$5 in interface PekkoPduCodec

constructMessage$default$6

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

Specified by:

constructMessage$default$6 in interface PekkoPduCodec

constructPureAck

public ByteString constructPureAck(Ack ack)

Specified by:

constructPureAck in interface PekkoPduCodec

constructPayload

public ByteString constructPayload(ByteString payload)

Specified by:

constructPayload in interface PekkoPduCodec

constructAssociate

public ByteString constructAssociate(HandshakeInfo info)

Specified by:

constructAssociate in interface PekkoPduCodec

constructDisassociate

public ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)

Specified by:

constructDisassociate in interface PekkoPduCodec

constructHeartbeat

public ByteString constructHeartbeat()

Specified by:

constructHeartbeat in interface PekkoPduCodec

decodePdu

public PekkoPduCodec.PekkoPdu decodePdu(ByteString raw)

Description copied from interface: PekkoPduCodec

Returns an pekko.remote.transport.PekkoPduCodec.PekkoPdu instance that represents the PDU contained in the raw ByteString.

Specified by:

decodePdu in interface PekkoPduCodec

Parameters:

raw - Encoded raw byte representation of a Pekko PDU

Returns:

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

decodeMessage

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

Specified by:

decodeMessage in interface PekkoPduCodec