Package akka.remote.artery

Class NoOpRemotingFlightRecorder

  • public class NoOpRemotingFlightRecorder
extends java.lang.Object
    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.

    INTERNAL

    • Constructor Detail

      • NoOpRemotingFlightRecorder

        public NoOpRemotingFlightRecorder()

    • Method Detail

      • transportMediaDriverStarted

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

      • transportStarted

        public static void transportStarted()

      • transportAeronErrorLogStarted

        public static void transportAeronErrorLogStarted()

      • transportTaskRunnerStarted

        public static void transportTaskRunnerStarted()

      • transportUniqueAddressSet

        public static void transportUniqueAddressSet​(UniqueAddress uniqueAddress)

      • transportMaterializerStarted

        public static void transportMaterializerStarted()

      • transportStartupFinished

        public static void transportStartupFinished()

      • transportKillSwitchPulled

        public static void transportKillSwitchPulled()

      • transportStopped

        public static void transportStopped()

      • transportAeronErrorLogTaskStopped

        public static void transportAeronErrorLogTaskStopped()

      • transportMediaFileDeleted

        public static void transportMediaFileDeleted()

      • transportStopIdleOutbound

        public static void transportStopIdleOutbound​(Address remoteAddress,
                                             int queueIndex)

      • transportQuarantined

        public static void transportQuarantined​(Address remoteAddress,
                                        long uid)

      • transportRemoveQuarantined

        public static void transportRemoveQuarantined​(Address remoteAddress)

      • transportRestartOutbound

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

      • transportRestartInbound

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

      • transportSendQueueOverflow

        public static void transportSendQueueOverflow​(int queueIndex)

      • aeronSinkStarted

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

      • aeronSinkTaskRunnerRemoved

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

      • aeronSinkPublicationClosed

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

      • aeronSinkPublicationClosedUnexpectedly

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

      • aeronSinkStopped

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

      • aeronSinkEnvelopeGrabbed

        public static void aeronSinkEnvelopeGrabbed​(int lastMessageSize)

      • aeronSinkEnvelopeOffered

        public static void aeronSinkEnvelopeOffered​(int lastMessageSize)

      • aeronSinkGaveUpEnvelope

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

      • aeronSinkDelegateToTaskRunner

        public static void aeronSinkDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSinkReturnFromTaskRunner

        public static void aeronSinkReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • aeronSourceStarted

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

      • aeronSourceStopped

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

      • aeronSourceReceived

        public static void aeronSourceReceived​(int size)

      • aeronSourceDelegateToTaskRunner

        public static void aeronSourceDelegateToTaskRunner​(long countBeforeDelegate)

      • aeronSourceReturnFromTaskRunner

        public static void aeronSourceReturnFromTaskRunner​(long nanosSinceTaskStartTime)

      • compressionActorRefAdvertisement

        public static void compressionActorRefAdvertisement​(long uid)

      • compressionClassManifestAdvertisement

        public static void compressionClassManifestAdvertisement​(long uid)

      • tcpOutboundConnected

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

      • tcpOutboundSent

        public static void tcpOutboundSent​(int size)

      • tcpInboundBound

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

      • tcpInboundUnbound

        public static void tcpInboundUnbound​(UniqueAddress localAddress)

      • tcpInboundConnected

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

      • tcpInboundReceived

        public static void tcpInboundReceived​(int size)

      • productPrefix

        public static java.lang.String productPrefix()

      • productArity

        public static int productArity()

      • productElement

        public static java.lang.Object productElement​(int x$1)

      • productIterator

        public static scala.collection.Iterator<java.lang.Object> productIterator()

      • canEqual

        public static boolean canEqual​(java.lang.Object x$1)

      • hashCode

        public static int hashCode()

      • toString

        public static java.lang.String toString()

      • equals

        public abstract static boolean equals​(java.lang.Object that)

      • productElementName

        public static java.lang.String productElementName​(int n)

      • productElementNames

        public static scala.collection.Iterator<java.lang.String> productElementNames()