|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.remote.transport.AkkaPduProtobufCodec
public class AkkaPduProtobufCodec
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 |
---|
public AkkaPduProtobufCodec()
Method Detail |
---|
public static ByteString constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, scala.Option<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
public static ByteString constructPureAck(Ack ack)
public static ByteString constructPayload(ByteString payload)
public static ByteString constructAssociate(HandshakeInfo info)
public static ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)
public static ByteString constructHeartbeat()
public static AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)
public static scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(ByteString raw, RemoteActorRefProvider provider, Address localAddress)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |