akka.remote.transport
Class AkkaPduProtobufCodec

java.lang.Object
  extended by 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)