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 and Description
AkkaPduProtobufCodec()

Method Summary

Modifier and Type	Method and 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, OptionVal<ActorRef> 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, RemoteActorRefProvider provider, Address localAddress)
static AkkaPduCodec.AkkaPdu	decodePdu(ByteString raw)
static ByteString	encodePdu(AkkaPduCodec.AkkaPdu pdu)

Methods inherited from class java.lang.Object

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

Constructor Detail

AkkaPduProtobufCodec

public AkkaPduProtobufCodec()

Method Detail

constructMessage

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

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,
                                                                                               RemoteActorRefProvider provider,
                                                                                               Address localAddress)

encodePdu

public static ByteString encodePdu(AkkaPduCodec.AkkaPdu pdu)

constructMessage$default$5

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

constructMessage$default$6

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