akka.remote.transport
Class AkkaPduProtobufCodec$
java.lang.Object
akka.remote.transport.AkkaPduProtobufCodec$
- All Implemented Interfaces:
- AkkaPduCodec
public class AkkaPduProtobufCodec$
- extends java.lang.Object
- implements AkkaPduCodec
INTERNAL API
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MODULE$
public static final AkkaPduProtobufCodec$ MODULE$
- Static reference to the singleton instance of this Scala object.
AkkaPduProtobufCodec$
public AkkaPduProtobufCodec$()
constructMessage
public ByteString constructMessage(Address localAddress,
ActorRef recipient,
WireFormats.SerializedMessage serializedMessage,
scala.Option<ActorRef> senderOption,
scala.Option<SeqNo> seqOption,
scala.Option<Ack> ackOption)
- Specified by:
constructMessage
in interface AkkaPduCodec
constructPureAck
public ByteString constructPureAck(Ack ack)
- Specified by:
constructPureAck
in interface AkkaPduCodec
constructPayload
public ByteString constructPayload(ByteString payload)
- Specified by:
constructPayload
in interface AkkaPduCodec
constructAssociate
public ByteString constructAssociate(HandshakeInfo info)
- Specified by:
constructAssociate
in interface AkkaPduCodec
constructDisassociate
public ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)
- Specified by:
constructDisassociate
in interface AkkaPduCodec
constructHeartbeat
public ByteString constructHeartbeat()
- Specified by:
constructHeartbeat
in interface AkkaPduCodec
decodePdu
public AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
- Description copied from interface:
AkkaPduCodec
- Returns an
AkkaPduCodec.AkkaPdu
instance that represents the PDU contained in the raw
ByteString.
- Specified by:
decodePdu
in interface AkkaPduCodec
- 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
decodeMessage
public scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw,
RemoteActorRefProvider provider,
Address localAddress)
- Specified by:
decodeMessage
in interface AkkaPduCodec