Package akka.remote.artery.tcp

Class ArteryTcpTransport

java.lang.Object

akka.remote.RemoteTransport

akka.remote.artery.ArteryTransport

akka.remote.artery.tcp.ArteryTcpTransport

All Implemented Interfaces:

InboundContext

public class ArteryTcpTransport
extends ArteryTransport

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.remote.artery.ArteryTransport

ArteryTransport.AeronTerminated, ArteryTransport.InboundStreamMatValues<LifeCycle>, ArteryTransport.InboundStreamMatValues$, ArteryTransport.ShutdownSignal$, ArteryTransport.ShuttingDown$

Constructor Summary

Constructors

Constructor	Description
ArteryTcpTransport(ExtendedActorSystem _system, RemoteActorRefProvider _provider, boolean tlsEnabled)

Method Summary

Modifier and Type	Method	Description
protected scala.Tuple2<java.lang.Object,java.lang.Object>	bindInboundStreams()	Bind to the ports for inbound streams.
static scala.util.Try<scala.runtime.BoxedUnit>	optionToTry(scala.Option<java.lang.Throwable> opt)
protected Sink<EnvelopeBuffer,scala.concurrent.Future<Done>>	outboundTransportSink(OutboundContext outboundContext, int streamId, EnvelopeBufferPool bufferPool)
protected void	runInboundStreams(int port, int bindPort)	Run the inbound streams that have been previously bound.
protected scala.concurrent.Future<Done>	shutdownTransport()
protected void	startTransport()

Methods inherited from class akka.remote.artery.ArteryTransport

_inboundCompressions, addresses, association, association, attachControlMessageObserver, attachInboundStreamRestart, bindAddress, completeHandshake, controlMaterializer, controlMaterializer_$eq, ControlStreamId, createDecoder, createDeserializer, createEncoder, defaultAddress, envelopeBufferPool, flightRecorder, HighestVersion, inboundCompressionAccess, inboundControlSink, inboundFlow, inboundLanePartitioner, inboundLanes, inboundLargeFlow, inboundSink, isShutdown, killSwitch, largeEnvelopeBufferPool, largeMessageChannelEnabled, LargeStreamId, localAddress, localAddressForRemote, log, managementCommand, materializer, materializer_$eq, messageDispatcherSink, OrdinaryStreamId, outbound, outboundControl, outboundLane, outboundLarge, outboundTestFlow, outboundTransportSink, ProtocolName, publishDropped, quarantine, quarantine, remoteAddresses, send, sendControl, setInboundCompressionAccess, settings, shutdown, start, streamMatValues, streamName, terminationHintReplier, triggerCompressionAdvertisements, updateStreamMatValues

Methods inherited from class akka.remote.RemoteTransport

provider, system

Methods inherited from class java.lang.Object

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

Constructor Detail

ArteryTcpTransport

public ArteryTcpTransport(ExtendedActorSystem _system,
                          RemoteActorRefProvider _provider,
                          boolean tlsEnabled)

Method Detail

optionToTry

public static scala.util.Try<scala.runtime.BoxedUnit> optionToTry(scala.Option<java.lang.Throwable> opt)

startTransport

protected void startTransport()

Specified by:

startTransport in class ArteryTransport

outboundTransportSink

protected Sink<EnvelopeBuffer,scala.concurrent.Future<Done>> outboundTransportSink(OutboundContext outboundContext,
                                                                                         int streamId,
                                                                                         EnvelopeBufferPool bufferPool)

Specified by:

outboundTransportSink in class ArteryTransport

bindInboundStreams

protected scala.Tuple2<java.lang.Object,java.lang.Object> bindInboundStreams()

Description copied from class: ArteryTransport

Bind to the ports for inbound streams. If '0' is specified, this will also select an arbitrary free local port. For UDP, we only select the port and leave the actual binding to Aeron when running the inbound stream.

After calling this method the 'localAddress' and 'bindAddress' fields can be set.

Specified by:

bindInboundStreams in class ArteryTransport

runInboundStreams

protected void runInboundStreams(int port,
                                 int bindPort)

Description copied from class: ArteryTransport

Run the inbound streams that have been previously bound.

Before calling this method the 'localAddress' and 'bindAddress' should have been set.

Specified by:

runInboundStreams in class ArteryTransport

shutdownTransport

protected scala.concurrent.Future<Done> shutdownTransport()

Specified by:

shutdownTransport in class ArteryTransport