Package org.apache.pekko.remote.artery

Class NoOpRemotingFlightRecorder

java.lang.Object
org.apache.pekko.remote.artery.NoOpRemotingFlightRecorder
public class NoOpRemotingFlightRecorder extends Object
JFR is only available under certain circumstances (but is usually available since Java 9).

INTERNAL

  • Constructor Details

    • NoOpRemotingFlightRecorder

      public NoOpRemotingFlightRecorder()

  • Method Details

    • transportMediaDriverStarted

      public static void transportMediaDriverStarted(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, String streamName)

    • transportRestartInbound

      public static void transportRestartInbound(UniqueAddress remoteAddress, String streamName)

    • transportSendQueueOverflow

      public static void transportSendQueueOverflow(int queueIndex)

    • aeronSinkStarted

      public static void aeronSinkStarted(String channel, int streamId)

    • aeronSinkTaskRunnerRemoved

      public static void aeronSinkTaskRunnerRemoved(String channel, int streamId)

    • aeronSinkPublicationClosed

      public static void aeronSinkPublicationClosed(String channel, int streamId)

    • aeronSinkPublicationClosedUnexpectedly

      public static void aeronSinkPublicationClosedUnexpectedly(String channel, int streamId)

    • aeronSinkStopped

      public static void aeronSinkStopped(String channel, int streamId)

    • aeronSinkEnvelopeGrabbed

      public static void aeronSinkEnvelopeGrabbed(int lastMessageSize)

    • aeronSinkEnvelopeOffered

      public static void aeronSinkEnvelopeOffered(int lastMessageSize)

    • aeronSinkGaveUpEnvelope

      public static void aeronSinkGaveUpEnvelope(String cause)

    • aeronSinkDelegateToTaskRunner

      public static void aeronSinkDelegateToTaskRunner(long countBeforeDelegate)

    • aeronSinkReturnFromTaskRunner

      public static void aeronSinkReturnFromTaskRunner(long nanosSinceTaskStartTime)

    • aeronSourceStarted

      public static void aeronSourceStarted(String channel, int streamId)

    • aeronSourceStopped

      public static void aeronSourceStopped(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, String streamName)

    • tcpOutboundSent

      public static void tcpOutboundSent(int size)

    • tcpInboundBound

      public static void tcpInboundBound(String bindHost, InetSocketAddress address)

    • tcpInboundUnbound

      public static void tcpInboundUnbound(UniqueAddress localAddress)

    • tcpInboundConnected

      public static void tcpInboundConnected(InetSocketAddress remoteAddress)

    • tcpInboundReceived

      public static void tcpInboundReceived(int size)

    • productPrefix

      public static String productPrefix()

    • productArity

      public static int productArity()

    • productElement

      public static Object productElement(int x$1)

    • productIterator

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

    • canEqual

      public static boolean canEqual(Object x$1)

    • hashCode

      public static int hashCode()

    • toString

      public static String toString()

    • equals

      public abstract static boolean equals(Object that)

    • productElementName

      public static String productElementName(int n)

    • productElementNames

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