org.springframework.cloud.stream.binder.rocketmq.metrics

Class Instrumentation

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

Direct Known Subclasses:

ConsumerGroupInstrumentation, ConsumerInstrumentation, ProducerInstrumentation

public class Instrumentation
extends Object

Author:

Timur Valiev, Jim

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicBoolean	started
protected Exception	startException

Method Summary

Modifier and Type	Method and Description
String	getName()
Exception	getStartException()
boolean	isDown()
boolean	isOutOfService()
boolean	isStarted()
boolean	isUp()
void	markStartedSuccessfully()
void	markStartFailed(Exception e)

Methods inherited from class java.lang.Object

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

Field Detail

started

protected final AtomicBoolean started

startException

protected Exception startException

Method Detail

isDown

public boolean isDown()

isUp

public boolean isUp()

isOutOfService

public boolean isOutOfService()

markStartedSuccessfully

public void markStartedSuccessfully()

markStartFailed

public void markStartFailed(Exception e)

getName

public String getName()

isStarted

public boolean isStarted()

getStartException

public Exception getStartException()