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

Nested Class Summary

Nested classes/interfaces inherited from interface akka.remote.transport.AkkaPduCodec

AkkaPduCodec.AkkaPdu, AkkaPduCodec.Associate, AkkaPduCodec.Associate$, AkkaPduCodec.Disassociate, AkkaPduCodec.Disassociate$, AkkaPduCodec.Heartbeat$, AkkaPduCodec.Message, AkkaPduCodec.Message$, AkkaPduCodec.Payload, AkkaPduCodec.Payload$

Constructor Summary

AkkaPduProtobufCodec()

Method Summary

static ByteString	constructAssociate(HandshakeInfo info)
static ByteString	constructDisassociate(AssociationHandle.DisassociateInfo info)
static ByteString	constructHeartbeat()
static ByteString	constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, scala.Option<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
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)

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.remote.transport.AkkaPduCodec

constructAssociate, constructDisassociate, constructHeartbeat, constructMessage, constructPayload, constructPureAck, decodeMessage, decodePdu, encodePdu

Constructor Detail

AkkaPduProtobufCodec

public AkkaPduProtobufCodec()

Method Detail

constructMessage

public static ByteString constructMessage(Address localAddress,
                                          ActorRef recipient,
                                          WireFormats.SerializedMessage serializedMessage,
                                          scala.Option<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)