Package akka.remote.artery

Class ReusableInboundEnvelope

java.lang.Object

akka.remote.artery.ReusableInboundEnvelope

All Implemented Interfaces:

NoSerializationVerificationNeeded, InboundEnvelope

public final class ReusableInboundEnvelope
extends java.lang.Object
implements InboundEnvelope

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
ReusableInboundEnvelope()

Method Summary

Modifier and Type	Method	Description
OptionVal<OutboundContext>	association()
java.lang.String	classManifest()
void	clear()
InboundEnvelope	copyForLane(int lane)
static ObjectPool<ReusableInboundEnvelope>	createObjectPool(int capacity)
EnvelopeBuffer	envelopeBuffer()
boolean	flag(ByteFlag byteFlag)
byte	flags()
InboundEnvelope	init(OptionVal<InternalActorRef> recipient, OptionVal<ActorRef> sender, long originUid, int serializer, java.lang.String classManifest, byte flags, EnvelopeBuffer envelopeBuffer, OptionVal<OutboundContext> association, int lane)
int	lane()
java.lang.Object	message()
long	originUid()
OptionVal<InternalActorRef>	recipient()
InboundEnvelope	releaseEnvelopeBuffer()
OptionVal<ActorRef>	sender()
int	serializer()
java.lang.String	toString()
InboundEnvelope	withEnvelopeBuffer(EnvelopeBuffer envelopeBuffer)
InboundEnvelope	withMessage(java.lang.Object message)
InboundEnvelope	withRecipient(InternalActorRef ref)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReusableInboundEnvelope

public ReusableInboundEnvelope()

Method Detail

createObjectPool

public static ObjectPool<ReusableInboundEnvelope> createObjectPool(int capacity)

recipient

public OptionVal<InternalActorRef> recipient()

Specified by:

recipient in interface InboundEnvelope

sender

public OptionVal<ActorRef> sender()

Specified by:

sender in interface InboundEnvelope

originUid

public long originUid()

Specified by:

originUid in interface InboundEnvelope

association

public OptionVal<OutboundContext> association()

Specified by:

association in interface InboundEnvelope

serializer

public int serializer()

Specified by:

serializer in interface InboundEnvelope

classManifest

public java.lang.String classManifest()

Specified by:

classManifest in interface InboundEnvelope

message

public java.lang.Object message()

Specified by:

message in interface InboundEnvelope

envelopeBuffer

public EnvelopeBuffer envelopeBuffer()

Specified by:

envelopeBuffer in interface InboundEnvelope

flags

public byte flags()

Specified by:

flags in interface InboundEnvelope

flag

public boolean flag(ByteFlag byteFlag)

Specified by:

flag in interface InboundEnvelope

lane

public int lane()

Specified by:

lane in interface InboundEnvelope

withMessage

public InboundEnvelope withMessage(java.lang.Object message)

Specified by:

withMessage in interface InboundEnvelope

releaseEnvelopeBuffer

public InboundEnvelope releaseEnvelopeBuffer()

Specified by:

releaseEnvelopeBuffer in interface InboundEnvelope

withRecipient

public InboundEnvelope withRecipient(InternalActorRef ref)

Specified by:

withRecipient in interface InboundEnvelope

clear

public void clear()

init

public InboundEnvelope init(OptionVal<InternalActorRef> recipient,
                            OptionVal<ActorRef> sender,
                            long originUid,
                            int serializer,
                            java.lang.String classManifest,
                            byte flags,
                            EnvelopeBuffer envelopeBuffer,
                            OptionVal<OutboundContext> association,
                            int lane)

withEnvelopeBuffer

public InboundEnvelope withEnvelopeBuffer(EnvelopeBuffer envelopeBuffer)

copyForLane

public InboundEnvelope copyForLane(int lane)

Specified by:

copyForLane in interface InboundEnvelope

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object