Package org.apache.pekko.remote.artery

Class NoOpRemotingFlightRecorder$

java.lang.Object

org.apache.pekko.remote.artery.NoOpRemotingFlightRecorder$

All Implemented Interfaces:

java.io.Serializable, Extension, RemotingFlightRecorder, scala.Equals, scala.Product

public class NoOpRemotingFlightRecorder$
extends java.lang.Object
implements RemotingFlightRecorder, scala.Product, java.io.Serializable

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static NoOpRemotingFlightRecorder$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
NoOpRemotingFlightRecorder$()

Method Summary

Modifier and Type	Method	Description
void	aeronSinkDelegateToTaskRunner(long countBeforeDelegate)
void	aeronSinkEnvelopeGrabbed(int lastMessageSize)
void	aeronSinkEnvelopeOffered(int lastMessageSize)
void	aeronSinkGaveUpEnvelope(java.lang.String cause)
void	aeronSinkPublicationClosed(java.lang.String channel, int streamId)
void	aeronSinkPublicationClosedUnexpectedly(java.lang.String channel, int streamId)
void	aeronSinkReturnFromTaskRunner(long nanosSinceTaskStartTime)
void	aeronSinkStarted(java.lang.String channel, int streamId)
void	aeronSinkStopped(java.lang.String channel, int streamId)
void	aeronSinkTaskRunnerRemoved(java.lang.String channel, int streamId)
void	aeronSourceDelegateToTaskRunner(long countBeforeDelegate)
void	aeronSourceReceived(int size)
void	aeronSourceReturnFromTaskRunner(long nanosSinceTaskStartTime)
void	aeronSourceStarted(java.lang.String channel, int streamId)
void	aeronSourceStopped(java.lang.String channel, int streamId)
boolean	canEqual(java.lang.Object x$1)
void	compressionActorRefAdvertisement(long uid)
void	compressionClassManifestAdvertisement(long uid)
int	hashCode()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
void	tcpInboundBound(java.lang.String bindHost, java.net.InetSocketAddress address)
void	tcpInboundConnected(java.net.InetSocketAddress remoteAddress)
void	tcpInboundReceived(int size)
void	tcpInboundUnbound(UniqueAddress localAddress)
void	tcpOutboundConnected(Address remoteAddress, java.lang.String streamName)
void	tcpOutboundSent(int size)
java.lang.String	toString()
void	transportAeronErrorLogStarted()
void	transportAeronErrorLogTaskStopped()
void	transportKillSwitchPulled()
void	transportMaterializerStarted()
void	transportMediaDriverStarted(java.lang.String directoryName)
void	transportMediaFileDeleted()
void	transportQuarantined(Address remoteAddress, long uid)
void	transportRemoveQuarantined(Address remoteAddress)
void	transportRestartInbound(UniqueAddress remoteAddress, java.lang.String streamName)
void	transportRestartOutbound(Address remoteAddress, java.lang.String streamName)
void	transportSendQueueOverflow(int queueIndex)
void	transportStarted()
void	transportStartupFinished()
void	transportStopIdleOutbound(Address remoteAddress, int queueIndex)
void	transportStopped()
void	transportTaskRunnerStarted()
void	transportUniqueAddressSet(UniqueAddress uniqueAddress)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

equals

Methods inherited from interface scala.Product

productElementName, productElementNames

Field Detail

MODULE$

public static final NoOpRemotingFlightRecorder$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

NoOpRemotingFlightRecorder$

public NoOpRemotingFlightRecorder$()

Method Detail

transportMediaDriverStarted

public void transportMediaDriverStarted(java.lang.String directoryName)

Specified by:

transportMediaDriverStarted in interface RemotingFlightRecorder

transportStarted

public void transportStarted()

Specified by:

transportStarted in interface RemotingFlightRecorder

transportAeronErrorLogStarted

public void transportAeronErrorLogStarted()

Specified by:

transportAeronErrorLogStarted in interface RemotingFlightRecorder

transportTaskRunnerStarted

public void transportTaskRunnerStarted()

Specified by:

transportTaskRunnerStarted in interface RemotingFlightRecorder

transportUniqueAddressSet

public void transportUniqueAddressSet(UniqueAddress uniqueAddress)

Specified by:

transportUniqueAddressSet in interface RemotingFlightRecorder

transportMaterializerStarted

public void transportMaterializerStarted()

Specified by:

transportMaterializerStarted in interface RemotingFlightRecorder

transportStartupFinished

public void transportStartupFinished()

Specified by:

transportStartupFinished in interface RemotingFlightRecorder

transportKillSwitchPulled

public void transportKillSwitchPulled()

Specified by:

transportKillSwitchPulled in interface RemotingFlightRecorder

transportStopped

public void transportStopped()

Specified by:

transportStopped in interface RemotingFlightRecorder

transportAeronErrorLogTaskStopped

public void transportAeronErrorLogTaskStopped()

Specified by:

transportAeronErrorLogTaskStopped in interface RemotingFlightRecorder

transportMediaFileDeleted

public void transportMediaFileDeleted()

Specified by:

transportMediaFileDeleted in interface RemotingFlightRecorder

transportStopIdleOutbound

public void transportStopIdleOutbound(Address remoteAddress,
                                      int queueIndex)

Specified by:

transportStopIdleOutbound in interface RemotingFlightRecorder

transportQuarantined

public void transportQuarantined(Address remoteAddress,
                                 long uid)

Specified by:

transportQuarantined in interface RemotingFlightRecorder

transportRemoveQuarantined

public void transportRemoveQuarantined(Address remoteAddress)

Specified by:

transportRemoveQuarantined in interface RemotingFlightRecorder

transportRestartOutbound

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

Specified by:

transportRestartOutbound in interface RemotingFlightRecorder

transportRestartInbound

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

Specified by:

transportRestartInbound in interface RemotingFlightRecorder

transportSendQueueOverflow

public void transportSendQueueOverflow(int queueIndex)

Specified by:

transportSendQueueOverflow in interface RemotingFlightRecorder

aeronSinkStarted

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

Specified by:

aeronSinkStarted in interface RemotingFlightRecorder

aeronSinkTaskRunnerRemoved

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

Specified by:

aeronSinkTaskRunnerRemoved in interface RemotingFlightRecorder

aeronSinkPublicationClosed

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

Specified by:

aeronSinkPublicationClosed in interface RemotingFlightRecorder

aeronSinkPublicationClosedUnexpectedly

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

Specified by:

aeronSinkPublicationClosedUnexpectedly in interface RemotingFlightRecorder

aeronSinkStopped

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

Specified by:

aeronSinkStopped in interface RemotingFlightRecorder

aeronSinkEnvelopeGrabbed

public void aeronSinkEnvelopeGrabbed(int lastMessageSize)

Specified by:

aeronSinkEnvelopeGrabbed in interface RemotingFlightRecorder

aeronSinkEnvelopeOffered

public void aeronSinkEnvelopeOffered(int lastMessageSize)

Specified by:

aeronSinkEnvelopeOffered in interface RemotingFlightRecorder

aeronSinkGaveUpEnvelope

public void aeronSinkGaveUpEnvelope(java.lang.String cause)

Specified by:

aeronSinkGaveUpEnvelope in interface RemotingFlightRecorder

aeronSinkDelegateToTaskRunner

public void aeronSinkDelegateToTaskRunner(long countBeforeDelegate)

Specified by:

aeronSinkDelegateToTaskRunner in interface RemotingFlightRecorder

aeronSinkReturnFromTaskRunner

public void aeronSinkReturnFromTaskRunner(long nanosSinceTaskStartTime)

Specified by:

aeronSinkReturnFromTaskRunner in interface RemotingFlightRecorder

aeronSourceStarted

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

Specified by:

aeronSourceStarted in interface RemotingFlightRecorder

aeronSourceStopped

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

Specified by:

aeronSourceStopped in interface RemotingFlightRecorder

aeronSourceReceived

public void aeronSourceReceived(int size)

Specified by:

aeronSourceReceived in interface RemotingFlightRecorder

aeronSourceDelegateToTaskRunner

public void aeronSourceDelegateToTaskRunner(long countBeforeDelegate)

Specified by:

aeronSourceDelegateToTaskRunner in interface RemotingFlightRecorder

aeronSourceReturnFromTaskRunner

public void aeronSourceReturnFromTaskRunner(long nanosSinceTaskStartTime)

Specified by:

aeronSourceReturnFromTaskRunner in interface RemotingFlightRecorder

compressionActorRefAdvertisement

public void compressionActorRefAdvertisement(long uid)

Specified by:

compressionActorRefAdvertisement in interface RemotingFlightRecorder

compressionClassManifestAdvertisement

public void compressionClassManifestAdvertisement(long uid)

Specified by:

compressionClassManifestAdvertisement in interface RemotingFlightRecorder

tcpOutboundConnected

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

Specified by:

tcpOutboundConnected in interface RemotingFlightRecorder

tcpOutboundSent

public void tcpOutboundSent(int size)

Specified by:

tcpOutboundSent in interface RemotingFlightRecorder

tcpInboundBound

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

Specified by:

tcpInboundBound in interface RemotingFlightRecorder

tcpInboundUnbound

public void tcpInboundUnbound(UniqueAddress localAddress)

Specified by:

tcpInboundUnbound in interface RemotingFlightRecorder

tcpInboundConnected

public void tcpInboundConnected(java.net.InetSocketAddress remoteAddress)

Specified by:

tcpInboundConnected in interface RemotingFlightRecorder

tcpInboundReceived

public void tcpInboundReceived(int size)

Specified by:

tcpInboundReceived in interface RemotingFlightRecorder

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

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

Specified by:

productElement in interface scala.Product

productIterator

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

Specified by:

productIterator in interface scala.Product

canEqual

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

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object