public class AkkaPduProtobufCodec extends java.lang.Object implements AkkaPduCodec
AkkaPduCodec.AkkaPdu, AkkaPduCodec.Associate, AkkaPduCodec.Associate$, AkkaPduCodec.Disassociate, AkkaPduCodec.Disassociate$, AkkaPduCodec.Heartbeat$, AkkaPduCodec.Message, AkkaPduCodec.Message$, AkkaPduCodec.Payload, AkkaPduCodec.Payload$
Constructor and Description |
---|
AkkaPduProtobufCodec() |
Modifier and Type | Method and Description |
---|---|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
constructAssociate, constructDisassociate, constructHeartbeat, constructMessage, constructPayload, constructPureAck, decodeMessage, decodePdu, encodePdu
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)
public static akka.util.ByteString constructPureAck(Ack ack)
public static akka.util.ByteString constructPayload(akka.util.ByteString payload)
public static akka.util.ByteString constructAssociate(HandshakeInfo info)
public static akka.util.ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)
public static akka.util.ByteString constructHeartbeat()
public static AkkaPduCodec.AkkaPdu decodePdu(akka.util.ByteString raw)
public static scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>> decodeMessage(akka.util.ByteString raw, RemoteActorRefProvider provider, akka.actor.Address localAddress)