Package akka.remote.artery.aeron

Class ArteryAeronUdpTransport

java.lang.Object

akka.remote.RemoteTransport

akka.remote.artery.ArteryTransport

akka.remote.artery.aeron.ArteryAeronUdpTransport

All Implemented Interfaces:

InboundContext

public class ArteryAeronUdpTransport
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
ArteryAeronUdpTransport(ExtendedActorSystem _system, RemoteActorRefProvider _provider)

Method Summary

Modifier and Type	Method	Description
int	autoSelectPort(java.lang.String hostname)
protected scala.Tuple2<java.lang.Object,java.lang.Object>	bindInboundStreams()	Bind to the ports for inbound streams.
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, afrFile, afrFileChannel, association, association, attachControlMessageObserver, attachInboundStreamRestart, bindAddress, completeHandshake, controlMaterializer, controlMaterializer_$eq, ControlStreamId, createDecoder, createDeserializer, createEncoder, createFlightRecorderEventSink, createFlightRecorderEventSink$default$1, 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, quarantine, quarantine, remoteAddresses, send, sendControl, setInboundCompressionAccess, settings, shutdown, start, streamMatValues, streamName, terminationHintReplier, topLevelFlightRecorder, 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

ArteryAeronUdpTransport

public ArteryAeronUdpTransport(ExtendedActorSystem _system,
                               RemoteActorRefProvider _provider)

Method Detail

autoSelectPort

public int autoSelectPort(java.lang.String hostname)

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

Returns:

(undocumented)

outboundTransportSink

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

Specified by:

outboundTransportSink 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

Parameters:

port - (undocumented)

bindPort - (undocumented)

shutdownTransport

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

Specified by:

shutdownTransport in class ArteryTransport

startTransport

protected void startTransport()

Specified by:

startTransport in class ArteryTransport