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$

Field Summary

Fields

Modifier and Type	Field and Description
static AkkaPduProtobufCodec$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
AkkaPduProtobufCodec$()

Method Summary

Modifier and Type	Method and Description
ByteString	constructAssociate(HandshakeInfo info)
ByteString	constructDisassociate(AssociationHandle.DisassociateInfo info)
ByteString	constructHeartbeat()
ByteString	constructMessage(Address localAddress, ActorRef recipient, WireFormats.SerializedMessage serializedMessage, OptionVal<ActorRef> senderOption, scala.Option<SeqNo> seqOption, scala.Option<Ack> ackOption)
ByteString	constructPayload(ByteString payload)
ByteString	constructPureAck(Ack ack)
scala.Tuple2<scala.Option<Ack>,scala.Option<AkkaPduCodec.Message>>	decodeMessage(ByteString raw, RemoteActorRefProvider provider, Address localAddress)
AkkaPduCodec.AkkaPdu	decodePdu(ByteString raw) Returns an AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw ByteString.

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

encodePdu

Field Detail

MODULE$

public static final AkkaPduProtobufCodec$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

AkkaPduProtobufCodec$

public AkkaPduProtobufCodec$()

Method Detail

constructMessage

public ByteString constructMessage(Address localAddress,
                                   ActorRef recipient,
                                   WireFormats.SerializedMessage serializedMessage,
                                   OptionVal<ActorRef> senderOption,
                                   scala.Option<SeqNo> seqOption,
                                   scala.Option<Ack> ackOption)

Specified by:

constructMessage in interface AkkaPduCodec

constructPureAck

public ByteString constructPureAck(Ack ack)

Specified by:

constructPureAck in interface AkkaPduCodec

constructPayload

public ByteString constructPayload(ByteString payload)

Specified by:

constructPayload in interface AkkaPduCodec

constructAssociate

public ByteString constructAssociate(HandshakeInfo info)

Specified by:

constructAssociate in interface AkkaPduCodec

constructDisassociate

public ByteString constructDisassociate(AssociationHandle.DisassociateInfo info)

Specified by:

constructDisassociate in interface AkkaPduCodec

constructHeartbeat

public ByteString constructHeartbeat()

Specified by:

constructHeartbeat in interface AkkaPduCodec

decodePdu

public AkkaPduCodec.AkkaPdu decodePdu(ByteString raw)

Description copied from interface: AkkaPduCodec

Returns an AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw ByteString.

Specified by:

decodePdu in interface AkkaPduCodec

Parameters:

raw - Encoded raw byte representation of an Akka PDU

Returns:

Case class representation of the decoded PDU that can be used in a match statement

decodeMessage

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

Specified by:

decodeMessage in interface AkkaPduCodec