Package akka.remote.artery

Interface Summary

Interface	Description
ArteryMessage	INTERNAL API: marker trait for protobuf-serializable artery messages
ArterySettings.Transport
Association.QueueWrapper
Association.StopSignal
ControlMessage	INTERNAL API Marker trait for control messages that can be sent via the system message sub-channel but don't need full reliable delivery.
Decoder.InboundCompressionAccess	Materialized value of Encoder which allows safely calling into the operator to interfact with compression tables.
Decoder.InboundCompressionAccessImpl
Encoder.OutboundCompressionAccess
HeaderBuilder	INTERNAL API
InboundContext	INTERNAL API Inbound API that is used by the stream operators.
InboundControlJunction.CallbackMessage
InboundControlJunction.ControlMessageObserver
InboundControlJunction.ControlMessageSubject	Observer subject for inbound control messages.
InboundEnvelope	INTERNAL API
OutboundContext	INTERNAL API Outbound association API that is used by the stream operators.
OutboundControlJunction.OutboundControlIngress
OutboundEnvelope	INTERNAL API
OutboundHandshake.HandshakeState
RemotingFlightRecorder	INTERNAL API
Reply	INTERNAL API: Marker trait for reply messages
SendQueue.ProducerApi<T>
SendQueue.QueueValue<T>
SendQueue.WakeupSignal
SystemMessageDelivery.AckedDeliveryMessage

Class Summary

Class	Description
ActorRefResolveCacheWithAddress	INTERNAL API
ActorSystemTerminating	INTERNAL API
ActorSystemTerminating$
ActorSystemTerminatingAck	INTERNAL API
ActorSystemTerminatingAck$
ArterySettings	INTERNAL API
ArterySettings.AeronUpd$
ArterySettings.Compression	INTERNAL API
ArterySettings.Compression$
ArterySettings.Tcp$
ArterySettings.TlsTcp$
ArterySettings$	INTERNAL API
ArteryTransport	INTERNAL API
ArteryTransport.InboundStreamMatValues<LifeCycle>
ArteryTransport.InboundStreamMatValues$
ArteryTransport$	INTERNAL API
Association	INTERNAL API
Association.DisabledQueueWrapper$
Association.LazyQueueWrapper
Association.LazyQueueWrapper$
Association.OutboundStreamMatValues
Association.OutboundStreamMatValues$
Association.QueueWrapperImpl
Association.QueueWrapperImpl$
Association.RemovedQueueWrapper$
Association$	INTERNAL API
AssociationRegistry	INTERNAL API
AssociationState	INTERNAL API
AssociationState.QuarantinedTimestamp
AssociationState.QuarantinedTimestamp$
AssociationState$	INTERNAL API
ByteFlag	INTERNAL API
ByteFlag$	INTERNAL API
CacheStatistics	INTERNAL API
CacheStatistics$
Decoder	INTERNAL API
Decoder$	INTERNAL API
Deserializer	INTERNAL API
DuplicateHandshakeReq	INTERNAL API: The HandshakeReq message must be passed in each inbound lane to ensure that it arrives before any application message.
Encoder	INTERNAL API
Encoder$	INTERNAL API
EnvelopeBuffer	INTERNAL API
EnvelopeBuffer$	INTERNAL API
EnvelopeBufferPool	INTERNAL API
FixedSizePartitionHub<T>	INTERNAL API
FixedSizePartitionQueue	INTERNAL API
FlushOnShutdown	INTERNAL API
FlushOnShutdown.Timeout$
FlushOnShutdown$	INTERNAL API
GracefulShutdownQuarantinedEvent
GracefulShutdownQuarantinedEvent$
HeaderBuilder$	INTERNAL API
HeaderBuilderImpl	INTERNAL API
ImmutableLongMap<A>	INTERNAL API Specialized Map for primitive Long keys to avoid allocations (boxing).
ImmutableLongMap$	INTERNAL API
InboundControlJunction	INTERNAL API
InboundControlJunction.Attach
InboundControlJunction.Attach$
InboundControlJunction.Dettach
InboundControlJunction.Dettach$
InboundControlJunction$	INTERNAL API
InboundEnvelope$	INTERNAL API
InboundHandshake	INTERNAL API
InboundQuarantineCheck	INTERNAL API
InboundTestStage	INTERNAL API
LruBoundedCache<K,V>	INTERNAL API
MessageDispatcher	INTERNAL API
NoOpRemotingFlightRecorder	JFR is only available under certain circumstances (JDK11 for now, possible OpenJDK 8 in the future) so therefore the default on JDK 8 needs to be a no-op flight recorder.
NoOpRemotingFlightRecorder$	JFR is only available under certain circumstances (JDK11 for now, possible OpenJDK 8 in the future) so therefore the default on JDK 8 needs to be a no-op flight recorder.
ObjectPool<A>	INTERNAL API
OutboundControlJunction	INTERNAL API
OutboundControlJunction$	INTERNAL API
OutboundEnvelope$	INTERNAL API
OutboundHandshake	INTERNAL API
OutboundHandshake.HandshakeReq
OutboundHandshake.HandshakeReq$
OutboundHandshake.HandshakeRsp
OutboundHandshake.HandshakeRsp$
OutboundHandshake$	INTERNAL API
OutboundTestStage	INTERNAL API
Quarantined	INTERNAL API
Quarantined$
QuarantinedEvent
QuarantinedEvent$
RemoteInstrument	INTERNAL API
RemoteInstruments	INTERNAL API
RemoteInstruments$	INTERNAL API
RemotingFlightRecorder$	INTERNAL API
RestartCounter	INTERNAL API: Thread safe "restarts with duration" counter
RestartCounter.State
RestartCounter.State$
RestartCounter$	INTERNAL API
ReusableInboundEnvelope	INTERNAL API
ReusableInboundEnvelope$	INTERNAL API
ReusableOutboundEnvelope	INTERNAL API
ReusableOutboundEnvelope$	INTERNAL API
SendQueue<T>	INTERNAL API
SendQueue$	INTERNAL API
SerializationFormatCache	INTERNAL API
SharedTestState	INTERNAL API: Thread safe mutable state that is shared among the test operators.
SystemMessageAcker	INTERNAL API
SystemMessageAcker$	INTERNAL API
SystemMessageDelivery	INTERNAL API
SystemMessageDelivery.Ack
SystemMessageDelivery.Ack$
SystemMessageDelivery.ClearSystemMessageDelivery	Sent when an incarnation of an Association is quarantined.
SystemMessageDelivery.ClearSystemMessageDelivery$
SystemMessageDelivery.Nack
SystemMessageDelivery.Nack$
SystemMessageDelivery.SystemMessageEnvelope
SystemMessageDelivery.SystemMessageEnvelope$
SystemMessageDelivery$	INTERNAL API
TestManagementCommands
TestManagementCommands.FailInboundStreamOnce	INTERNAL API
TestManagementCommands.FailInboundStreamOnce$
TestManagementCommands$
TestState	INTERNAL API
TestState$
ThisActorSystemQuarantinedEvent
ThisActorSystemQuarantinedEvent$

Exception Summary

Exception	Description
ArteryTransport.AeronTerminated
ArteryTransport.ShutdownSignal$
ArteryTransport.ShuttingDown$
Association.OutboundStreamStopIdleSignal$
Association.OutboundStreamStopQuarantinedSignal$
OutboundHandshake.HandshakeTimeoutException	Stream is failed with this exception if the handshake is not completed within the handshake timeout.
OutOfBuffersException	INTERNAL API
SystemMessageDelivery.GaveUpSystemMessageException