public class AkkaPduProtobufCodec$ extends java.lang.Object implements AkkaPduCodec
AkkaPduCodec.AkkaPdu, AkkaPduCodec.Associate, AkkaPduCodec.Associate$, AkkaPduCodec.Disassociate, AkkaPduCodec.Disassociate$, AkkaPduCodec.Heartbeat$, AkkaPduCodec.Message, AkkaPduCodec.Message$, AkkaPduCodec.Payload, AkkaPduCodec.Payload$
Modifier and Type | Field and Description |
---|---|
static AkkaPduProtobufCodec$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
AkkaPduProtobufCodec$() |
Modifier and Type | Method and Description |
---|---|
ByteString |
constructAssociate(HandshakeInfo info) |
ByteString |
constructDisassociate(AssociationHandle.DisassociateInfo info) |
ByteString |
constructHeartbeat() |
ByteString |
constructMessage(Address localAddress,
ActorRef recipient,
WireFormats.SerializedMessage serializedMessage,
OptionVal<ActorRef> senderOption,
scala.Option<SeqNo> seqOption,
scala.Option<Ack> ackOption) |
ByteString |
constructPayload(ByteString payload) |
ByteString |
constructPureAck(Ack ack) |
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> |
decodeMessage(ByteString raw,
RemoteActorRefProvider provider,
Address localAddress) |
AkkaPduCodec.AkkaPdu |
decodePdu(ByteString raw)
Returns an
AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw
ByteString. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
encodePdu
public static final AkkaPduProtobufCodec$ MODULE$
public ByteString constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, OptionVal<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
constructMessage
in interface AkkaPduCodec
public ByteString constructPureAck(Ack ack)
constructPureAck
in interface AkkaPduCodec
public ByteString constructPayload(ByteString payload)
constructPayload
in interface AkkaPduCodec
public ByteString constructAssociate(HandshakeInfo info)
constructAssociate
in interface AkkaPduCodec
public ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)
constructDisassociate
in interface AkkaPduCodec
public ByteString constructHeartbeat()
constructHeartbeat
in interface AkkaPduCodec
public AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
AkkaPduCodec
AkkaPduCodec.AkkaPdu
instance that represents the PDU contained in the raw
ByteString.decodePdu
in interface AkkaPduCodec
raw
- Encoded raw byte representation of an Akka PDUpublic scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw, RemoteActorRefProvider provider, Address localAddress)
decodeMessage
in interface AkkaPduCodec