Class CoherenceConfigurationClient

java.lang.Object
io.micronaut.coherence.discovery.CoherenceConfigurationClient
All Implemented Interfaces:
io.micronaut.core.naming.Described, io.micronaut.discovery.config.ConfigurationClient

@Singleton @Requires(beans=CoherenceClientConfiguration.class) public class CoherenceConfigurationClient extends Object implements io.micronaut.discovery.config.ConfigurationClient
A ConfigurationClient that works with Coherence as a config source.
  • Constructor Details

    • CoherenceConfigurationClient

      public CoherenceConfigurationClient(io.micronaut.runtime.ApplicationConfiguration applicationConfiguration, CoherenceClientConfiguration coherenceClientConfiguration)
  • Method Details

    • getPropertySources

      public org.reactivestreams.Publisher<io.micronaut.context.env.PropertySource> getPropertySources(io.micronaut.context.env.Environment environment)
      Specified by:
      getPropertySources in interface io.micronaut.discovery.config.ConfigurationClient
    • buildSourceNames

      protected Map<Integer,String> buildSourceNames(io.micronaut.runtime.ApplicationConfiguration applicationConfiguration, io.micronaut.context.env.Environment environment)
      Build a map of config source names.
      Parameters:
      applicationConfiguration - the application configuration
      environment - the current environment
      Returns:
      a map of config source names
    • buildSession

      protected com.tangosol.net.Session buildSession(CoherenceClientConfiguration coherenceClientConfiguration)
      Builds Coherence session.
      Parameters:
      coherenceClientConfiguration - configuration
      Returns:
      Coherence session
    • buildChannel

      protected io.grpc.Channel buildChannel(CoherenceClientConfiguration coherenceClientConfiguration)
      Builds gRPC channel.
      Parameters:
      coherenceClientConfiguration - configuration
      Returns:
      gRPC channel
    • getDescription

      public String getDescription()
      Specified by:
      getDescription in interface io.micronaut.core.naming.Described