akka.remote.artery

Class RemoteInstruments

java.lang.Object

akka.remote.artery.RemoteInstruments

public final class RemoteInstruments
extends java.lang.Object

INTERNAL API

The 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 and Description
RemoteInstruments(ExtendedActorSystem system)
RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log)
RemoteInstruments(ExtendedActorSystem system, LoggingAdapter log, scala.collection.immutable.Vector<RemoteInstrument> _instruments)

Method Summary

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

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

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()