public static final class ConsulServiceCallServerListStrategies.OnDemand
extends org.apache.camel.impl.remote.DefaultServiceCallServerListStrategy<org.apache.camel.spi.ServiceCallServer>
Constructor and Description |
---|
OnDemand(ConsulConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected com.orbitz.consul.CatalogClient |
getCatalogClient() |
protected com.orbitz.consul.option.CatalogOptions |
getCatalogOptions() |
protected com.orbitz.consul.Consul |
getClient() |
protected com.orbitz.consul.HealthClient |
getHealthClient() |
List<org.apache.camel.spi.ServiceCallServer> |
getUpdatedListOfServers(String name) |
protected boolean |
hasFailingChecks(com.orbitz.consul.model.catalog.CatalogService service,
List<com.orbitz.consul.model.health.ServiceHealth> healths) |
protected boolean |
isCheckOnService(com.orbitz.consul.model.health.ServiceHealth check,
com.orbitz.consul.model.catalog.CatalogService service) |
protected boolean |
isNotHealthy(com.orbitz.consul.model.health.HealthCheck check) |
protected boolean |
isNotHealthy(com.orbitz.consul.model.health.ServiceHealth health) |
protected org.apache.camel.spi.ServiceCallServer |
newServer(com.orbitz.consul.model.catalog.CatalogService service) |
String |
toString() |
doStart, doStop, getCamelContext, getInitialListOfServers, setCamelContext
public OnDemand(ConsulConfiguration configuration) throws Exception
Exception
public List<org.apache.camel.spi.ServiceCallServer> getUpdatedListOfServers(String name)
getUpdatedListOfServers
in interface org.apache.camel.spi.ServiceCallServerListStrategy<org.apache.camel.spi.ServiceCallServer>
getUpdatedListOfServers
in class org.apache.camel.impl.remote.DefaultServiceCallServerListStrategy<org.apache.camel.spi.ServiceCallServer>
public String toString()
protected com.orbitz.consul.Consul getClient()
protected com.orbitz.consul.CatalogClient getCatalogClient()
protected com.orbitz.consul.HealthClient getHealthClient()
protected com.orbitz.consul.option.CatalogOptions getCatalogOptions()
protected boolean isNotHealthy(com.orbitz.consul.model.health.HealthCheck check)
protected boolean isNotHealthy(com.orbitz.consul.model.health.ServiceHealth health)
protected boolean isCheckOnService(com.orbitz.consul.model.health.ServiceHealth check, com.orbitz.consul.model.catalog.CatalogService service)
protected boolean hasFailingChecks(com.orbitz.consul.model.catalog.CatalogService service, List<com.orbitz.consul.model.health.ServiceHealth> healths)
protected org.apache.camel.spi.ServiceCallServer newServer(com.orbitz.consul.model.catalog.CatalogService service)
Apache Camel