Package akka.remote.transport
Class AkkaPduProtobufCodec
- java.lang.Object
-
- akka.remote.transport.AkkaPduProtobufCodec
-
public class AkkaPduProtobufCodec extends java.lang.Object
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description AkkaPduProtobufCodec()
-
Method Summary
All Methods Static Methods Concrete Methods 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<AkkaPduCodec.Message>>
decodeMessage(ByteString raw, akka.remote.RemoteActorRefProvider provider, Address localAddress)
static AkkaPduCodec.AkkaPdu
decodePdu(ByteString raw)
static ByteString
encodePdu(AkkaPduCodec.AkkaPdu pdu)
-
-
-
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 AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
-
decodeMessage
public static scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw, akka.remote.RemoteActorRefProvider provider, Address localAddress)
-
encodePdu
public static ByteString encodePdu(AkkaPduCodec.AkkaPdu pdu)
-
-