Package org.apache.camel.impl.cloud
Class StaticServiceDiscovery
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.impl.cloud.DefaultServiceDiscovery
-
- org.apache.camel.impl.cloud.StaticServiceDiscovery
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.cloud.ServiceDiscovery
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class StaticServiceDiscovery extends DefaultServiceDiscovery
A static list of known servers Camel Service Call EIP.
-
-
Constructor Summary
Constructors Constructor Description StaticServiceDiscovery()
StaticServiceDiscovery(List<org.apache.camel.cloud.ServiceDefinition> servers)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addServer(String serverString)
Add a server to the known list of servers.void
addServer(org.apache.camel.cloud.ServiceDefinition server)
Add a server to the known list of servers.void
addServers(String serviceName, List<String> servers)
static StaticServiceDiscovery
forServices(Collection<org.apache.camel.cloud.ServiceDefinition> definitions)
static StaticServiceDiscovery
forServices(org.apache.camel.cloud.ServiceDefinition... definitions)
List<org.apache.camel.cloud.ServiceDefinition>
getServices(String name)
void
removeServer(Predicate<org.apache.camel.cloud.ServiceDefinition> condition)
Remove an existing server from the list of known servers.void
setServers(String servers)
Set the servers.void
setServers(List<String> servers)
Set the servers.-
Methods inherited from class org.apache.camel.impl.cloud.DefaultServiceDiscovery
doStart, doStop, getCamelContext, setCamelContext
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Constructor Detail
-
StaticServiceDiscovery
public StaticServiceDiscovery()
-
StaticServiceDiscovery
public StaticServiceDiscovery(List<org.apache.camel.cloud.ServiceDefinition> servers)
-
-
Method Detail
-
setServers
public void setServers(List<String> servers)
Set the servers.- Parameters:
servers
- server in the format: [service@]host:port.
-
setServers
public void setServers(String servers)
Set the servers.- Parameters:
servers
- servers separated by comma in the format: [service@]host:port,[service@]host2:port,[service@]host3:port and so on.
-
addServer
public void addServer(org.apache.camel.cloud.ServiceDefinition server)
Add a server to the known list of servers.
-
addServer
public void addServer(String serverString)
Add a server to the known list of servers.- Parameters:
serverString
- servers separated by comma in the format: [service@]host:port,[service@]host2:port,[service@]host3:port and so on.
-
removeServer
public void removeServer(Predicate<org.apache.camel.cloud.ServiceDefinition> condition)
Remove an existing server from the list of known servers.
-
getServices
public List<org.apache.camel.cloud.ServiceDefinition> getServices(String name)
- Specified by:
getServices
in interfaceorg.apache.camel.cloud.ServiceDiscovery
- Overrides:
getServices
in classDefaultServiceDiscovery
-
forServices
public static StaticServiceDiscovery forServices(Collection<org.apache.camel.cloud.ServiceDefinition> definitions)
-
forServices
public static StaticServiceDiscovery forServices(org.apache.camel.cloud.ServiceDefinition... definitions)
-
-