@Requires(property="endpoints.health.rabbitmq.enabled",notEquals="false") @Requires(beans=io.micronaut.management.endpoint.health.HealthEndpoint.class)
@Singleton
public class RabbitMQHealthIndicator
extends io.micronaut.management.health.indicator.AbstractHealthIndicator<java.util.Map<java.lang.String,java.lang.Object>>
HealthIndicator
for RabbitMQ.Constructor and Description |
---|
RabbitMQHealthIndicator(com.rabbitmq.client.Connection connection)
Default constructor.
|
RabbitMQHealthIndicator(java.util.List<com.rabbitmq.client.Connection> connections)
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.lang.Object> |
getDetails(com.rabbitmq.client.Connection connection) |
protected java.util.Map<java.lang.String,java.lang.Object> |
getHealthInformation() |
protected java.lang.String |
getName() |
getHealthResult, getResult, setExecutorService
public RabbitMQHealthIndicator(com.rabbitmq.client.Connection connection)
connection
- The connection to query for details@Inject public RabbitMQHealthIndicator(java.util.List<com.rabbitmq.client.Connection> connections)
connections
- The connections to query for detailsprotected java.util.Map<java.lang.String,java.lang.Object> getHealthInformation()
getHealthInformation
in class io.micronaut.management.health.indicator.AbstractHealthIndicator<java.util.Map<java.lang.String,java.lang.Object>>
protected java.util.Map<java.lang.String,java.lang.Object> getDetails(com.rabbitmq.client.Connection connection)
connection
- The connectionprotected java.lang.String getName()
getName
in class io.micronaut.management.health.indicator.AbstractHealthIndicator<java.util.Map<java.lang.String,java.lang.Object>>