Package akka.remote.artery
Class RemoteInstruments
- java.lang.Object
-
- akka.remote.artery.RemoteInstruments
-
public final class RemoteInstruments extends java.lang.Object
INTERNAL APIThe metadata section is stored as raw bytes (prefixed with an Int length field, the same way as any other literal), however the internal structure of it is as follows:
Metadata entry: 0 1 2 3 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | Key | Metadata entry length | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ | ... metadata entry ... | +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
-
-
Constructor Summary
Constructors Constructor Description RemoteInstruments(ExtendedActorSystem system)
RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log)
RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log, scala.collection.immutable.Vector<RemoteInstrument> _instruments)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static RemoteInstruments
apply(ExtendedActorSystem system)
static int
combineKeyLength(byte k, int l)
static scala.collection.immutable.Vector<RemoteInstrument>
create(ExtendedActorSystem system, LoggingAdapter log)
void
deserialize(InboundEnvelope inboundEnvelope)
void
deserializeRaw(InboundEnvelope inboundEnvelope)
static byte
getKey(int kl)
static int
getLength(int kl)
boolean
isEmpty()
void
messageReceived(InboundEnvelope inboundEnvelope, int size, long time)
void
messageSent(OutboundEnvelope outboundEnvelope, int size, long time)
boolean
nonEmpty()
void
serialize(OptionVal<OutboundEnvelope> outboundEnvelope, java.nio.ByteBuffer buffer)
boolean
timeSerialization()
-
-
-
Constructor Detail
-
RemoteInstruments
public RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log, scala.collection.immutable.Vector<RemoteInstrument> _instruments)
-
RemoteInstruments
public RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log)
-
RemoteInstruments
public RemoteInstruments(ExtendedActorSystem system)
-
-
Method Detail
-
apply
public static RemoteInstruments apply(ExtendedActorSystem system)
-
combineKeyLength
public static int combineKeyLength(byte k, int l)
-
getKey
public static byte getKey(int kl)
-
getLength
public static int getLength(int kl)
-
create
public static scala.collection.immutable.Vector<RemoteInstrument> create(ExtendedActorSystem system, LoggingAdapter log)
-
serialize
public void serialize(OptionVal<OutboundEnvelope> outboundEnvelope, java.nio.ByteBuffer buffer)
-
deserialize
public void deserialize(InboundEnvelope inboundEnvelope)
-
deserializeRaw
public void deserializeRaw(InboundEnvelope inboundEnvelope)
-
messageSent
public void messageSent(OutboundEnvelope outboundEnvelope, int size, long time)
-
messageReceived
public void messageReceived(InboundEnvelope inboundEnvelope, int size, long time)
-
isEmpty
public boolean isEmpty()
-
nonEmpty
public boolean nonEmpty()
-
timeSerialization
public boolean timeSerialization()
-
-