Package akka.remote.artery

Class RemotingFlightRecorder$

  • public class RemotingFlightRecorder$
extends java.lang.Object
    INTERNAL API

    • Field Detail

      • MODULE$

        public static final RemotingFlightRecorder$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • RemotingFlightRecorder$

        public RemotingFlightRecorder$()

    • Method Detail

      • transportMediaDriverStarted

        public void transportMediaDriverStarted​(java.lang.String directoryName)

      • transportStarted

        public void transportStarted()

      • transportAeronErrorLogStarted

        public void transportAeronErrorLogStarted()

      • transportTaskRunnerStarted

        public void transportTaskRunnerStarted()

      • transportUniqueAddressSet

        public void transportUniqueAddressSet​(UniqueAddress uniqueAddress)

      • transportMaterializerStarted

        public void transportMaterializerStarted()

      • transportStartupFinished

        public void transportStartupFinished()

      • transportKillSwitchPulled

        public void transportKillSwitchPulled()

      • transportStopped

        public void transportStopped()

      • transportAeronErrorLogTaskStopped

        public void transportAeronErrorLogTaskStopped()

      • transportMediaFileDeleted

        public void transportMediaFileDeleted()

      • transportSendQueueOverflow

        public void transportSendQueueOverflow​(int queueIndex)

      • transportStopIdleOutbound

        public void transportStopIdleOutbound​(Address remoteAddress,
                                      int queueIndex)

      • transportQuarantined

        public void transportQuarantined​(Address remoteAddress,
                                 long uid)

      • transportRemoveQuarantined

        public void transportRemoveQuarantined​(Address remoteAddress)

      • transportRestartOutbound

        public void transportRestartOutbound​(Address remoteAddress,
                                     java.lang.String streamName)

      • transportRestartInbound

        public void transportRestartInbound​(UniqueAddress remoteAddress,
                                    java.lang.String streamName)

      • aeronSinkStarted

        public void aeronSinkStarted​(java.lang.String channel,
                             int streamId)

      • aeronSinkTaskRunnerRemoved

        public void aeronSinkTaskRunnerRemoved​(java.lang.String channel,
                                       int streamId)

      • aeronSinkPublicationClosed

        public void aeronSinkPublicationClosed​(java.lang.String channel,
                                       int streamId)

      • aeronSinkPublicationClosedUnexpectedly

        public void aeronSinkPublicationClosedUnexpectedly​(java.lang.String channel,
                                                   int streamId)

      • aeronSinkStopped

        public void aeronSinkStopped​(java.lang.String channel,
                             int streamId)

      • aeronSinkEnvelopeGrabbed

        public void aeronSinkEnvelopeGrabbed​(int lastMessageSize)

      • aeronSinkEnvelopeOffered

        public void aeronSinkEnvelopeOffered​(int lastMessageSize)

      • aeronSinkGaveUpEnvelope

        public void aeronSinkGaveUpEnvelope​(java.lang.String cause)

      • aeronSinkDelegateToTaskRunner

        public void aeronSinkDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSinkReturnFromTaskRunner

        public void aeronSinkReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • aeronSourceStarted

        public void aeronSourceStarted​(java.lang.String channel,
                               int streamId)

      • aeronSourceStopped

        public void aeronSourceStopped​(java.lang.String channel,
                               int streamId)

      • aeronSourceReceived

        public void aeronSourceReceived​(int size)

      • aeronSourceDelegateToTaskRunner

        public void aeronSourceDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSourceReturnFromTaskRunner

        public void aeronSourceReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • compressionActorRefAdvertisement

        public void compressionActorRefAdvertisement​(long uid)

      • compressionClassManifestAdvertisement

        public void compressionClassManifestAdvertisement​(long uid)

      • tcpOutboundConnected

        public void tcpOutboundConnected​(Address remoteAddress,
                                 java.lang.String streamName)

      • tcpOutboundSent

        public void tcpOutboundSent​(int size)

      • tcpInboundBound

        public void tcpInboundBound​(java.lang.String bindHost,
                            java.net.InetSocketAddress address)

      • tcpInboundUnbound

        public void tcpInboundUnbound​(UniqueAddress localAddress)

      • tcpInboundConnected

        public void tcpInboundConnected​(java.net.InetSocketAddress remoteAddress)

      • tcpInboundReceived

        public void tcpInboundReceived​(int size)