io.micronaut.discovery.consul.registration

Class ConsulAutoRegistration

java.lang.Object

io.micronaut.discovery.registration.AutoRegistration

io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

io.micronaut.discovery.consul.registration.ConsulAutoRegistration

All Implemented Interfaces:

ApplicationEventListener<AbstractServiceInstanceEvent>, java.util.EventListener

@Singleton
 @Requires(beans={ConsulClient.class,ConsulConfiguration.class})
public class ConsulAutoRegistration
extends DiscoveryServiceAutoRegistration

Auto registration implementation for consul.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields inherited from class io.micronaut.discovery.registration.AutoRegistration

LOG, registered

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConsulAutoRegistration(Environment environment, ConsulClient consulClient, HeartbeatConfiguration heartbeatConfiguration, ConsulConfiguration consulConfiguration, ServiceInstanceIdGenerator idGenerator)

Method Summary

Modifier and Type	Method and Description
protected void	customizeServiceEntry(ServiceInstance instance, NewServiceEntry serviceEntry) Allows sub classes to override and customize the configuration.
protected void	deregister(ServiceInstance instance) Deregister the ServiceInstance from service discovery services.
protected void	pulsate(ServiceInstance instance, HealthStatus status) This method will be invoked each time a HeartbeatEvent occurs allowing the implementation to perform any necessary callbacks to the service discovery server.
protected void	register(ServiceInstance instance) Register the ServiceInstance with discovery services.

Methods inherited from class io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

getErrorMessage, performDeregistration, performRegistration

Methods inherited from class io.micronaut.discovery.registration.AutoRegistration

onApplicationEvent, validateApplicationName, validateName

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.event.ApplicationEventListener

supports

Constructor Detail

ConsulAutoRegistration

protected ConsulAutoRegistration(Environment environment,
                                 ConsulClient consulClient,
                                 HeartbeatConfiguration heartbeatConfiguration,
                                 ConsulConfiguration consulConfiguration,
                                 ServiceInstanceIdGenerator idGenerator)

Parameters:

environment - The environment

consulClient - The Consul client

heartbeatConfiguration - The heartbeat configuration

consulConfiguration - The Consul configuration

idGenerator - The id generator

Method Detail

pulsate

protected void pulsate(ServiceInstance instance,
                       HealthStatus status)

Description copied from class: AutoRegistration

This method will be invoked each time a HeartbeatEvent occurs allowing the implementation to perform any necessary callbacks to the service discovery server.

Specified by:

pulsate in class AutoRegistration

Parameters:

instance - The instance

status - The HealthStatus

deregister

protected void deregister(ServiceInstance instance)

Description copied from class: AutoRegistration

Deregister the ServiceInstance from service discovery services.

Specified by:

deregister in class AutoRegistration

Parameters:

instance - The ServiceInstance

register

protected void register(ServiceInstance instance)

Description copied from class: AutoRegistration

Register the ServiceInstance with discovery services.

Specified by:

register in class AutoRegistration

Parameters:

instance - The ServiceInstance

customizeServiceEntry

protected void customizeServiceEntry(ServiceInstance instance,
                                     NewServiceEntry serviceEntry)

Allows sub classes to override and customize the configuration.

Parameters:

instance - The instance

serviceEntry - The service entry