io.micronaut.discovery.client.registration

Class DiscoveryServiceAutoRegistration

java.lang.Object

io.micronaut.discovery.registration.AutoRegistration

io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

All Implemented Interfaces:

ApplicationEventListener<AbstractServiceInstanceEvent>, java.util.EventListener

Direct Known Subclasses:

ConsulAutoRegistration, EurekaAutoRegistration

public abstract class DiscoveryServiceAutoRegistration
extends AutoRegistration

Abstract class for AutoRegistration with discovery services.

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	DiscoveryServiceAutoRegistration(RegistrationConfiguration registrationConfiguration)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	getErrorMessage(java.lang.Throwable e, java.lang.String description)
protected void	performDeregistration(java.lang.String discoveryService, RegistrationConfiguration registration, org.reactivestreams.Publisher<HttpStatus> deregisterPublisher, java.lang.String applicationName) De-register a service from the discovery client.
protected void	performRegistration(java.lang.String discoveryService, RegistrationConfiguration registration, ServiceInstance instance, org.reactivestreams.Publisher<HttpStatus> registrationObservable) Register a new service instance in the discovery service.

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

deregister, onApplicationEvent, pulsate, register, 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

DiscoveryServiceAutoRegistration

protected DiscoveryServiceAutoRegistration(RegistrationConfiguration registrationConfiguration)

Parameters:

registrationConfiguration - The registration configuration

Method Detail

performRegistration

protected void performRegistration(java.lang.String discoveryService,
                                   RegistrationConfiguration registration,
                                   ServiceInstance instance,
                                   org.reactivestreams.Publisher<HttpStatus> registrationObservable)

Register a new service instance in the discovery service.

Parameters:

discoveryService - The discovery service

registration - The registration configuration

instance - The service instance

registrationObservable - The registration observable

getErrorMessage

protected java.lang.String getErrorMessage(java.lang.Throwable e,
                                           java.lang.String description)

Parameters:

e - The throwable

description - The error's description

Returns:

The error message

performDeregistration

protected void performDeregistration(java.lang.String discoveryService,
                                     RegistrationConfiguration registration,
                                     org.reactivestreams.Publisher<HttpStatus> deregisterPublisher,
                                     java.lang.String applicationName)

De-register a service from the discovery client.

Parameters:

discoveryService - The discovery service

registration - The registration configuration

deregisterPublisher - The registration publisher

applicationName - The application name to de-register