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 akka.util.ByteString	constructAssociate(HandshakeInfo info)
static akka.util.ByteString	constructDisassociate(AssociationHandle.DisassociateInfo info)
static akka.util.ByteString	constructHeartbeat()
static akka.util.ByteString	constructMessage(akka.actor.Address localAddress, akka.actor.ActorRef recipient, WireFormats.SerializedMessage serializedMessage, scala.Option<akka.actor.ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
static akka.util.ByteString	constructPayload(akka.util.ByteString payload)
static akka.util.ByteString	constructPureAck(Ack ack)
static scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>>	decodeMessage(akka.util.ByteString raw, RemoteActorRefProvider provider, akka.actor.Address localAddress)
static AkkaPduCodec.AkkaPdu	decodePdu(akka.util.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 akka.util.ByteString constructMessage(akka.actor.Address localAddress,
                                                    akka.actor.ActorRef recipient,
                                                    WireFormats.SerializedMessage serializedMessage,
                                                    scala.Option<akka.actor.ActorRef> senderOption,
                                                    scala.Option<SeqNo> seqOption,
                                                    scala.Option<Ack> ackOption)

constructPureAck

public static akka.util.ByteString constructPureAck(Ack ack)

constructPayload

public static akka.util.ByteString constructPayload(akka.util.ByteString payload)

constructAssociate

public static akka.util.ByteString constructAssociate(HandshakeInfo info)

constructDisassociate

public static akka.util.ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)

constructHeartbeat

public static akka.util.ByteString constructHeartbeat()

decodePdu

public static AkkaPduCodec.AkkaPdu decodePdu(akka.util.ByteString raw)

decodeMessage

public static scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(akka.util.ByteString raw,
                                                                                               RemoteActorRefProvider provider,
                                                                                               akka.actor.Address localAddress)