Package org.apache.camel.impl.cloud
Class DefaultServiceLoadBalancer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.impl.cloud.DefaultServiceLoadBalancer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.cloud.ServiceChooserAware
,org.apache.camel.cloud.ServiceDiscoveryAware
,org.apache.camel.cloud.ServiceFilterAware
,org.apache.camel.cloud.ServiceLoadBalancer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class DefaultServiceLoadBalancer extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.CamelContextAware, org.apache.camel.cloud.ServiceDiscoveryAware, org.apache.camel.cloud.ServiceChooserAware, org.apache.camel.cloud.ServiceFilterAware, org.apache.camel.cloud.ServiceLoadBalancer
-
-
Constructor Summary
Constructors Constructor Description DefaultServiceLoadBalancer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doStart()
protected void
doStop()
org.apache.camel.CamelContext
getCamelContext()
org.apache.camel.cloud.ServiceChooser
getServiceChooser()
org.apache.camel.cloud.ServiceDiscovery
getServiceDiscovery()
org.apache.camel.cloud.ServiceFilter
getServiceFilter()
<T> T
process(org.apache.camel.Exchange exchange, String serviceName, org.apache.camel.cloud.ServiceLoadBalancerFunction<T> function)
void
setCamelContext(org.apache.camel.CamelContext camelContext)
void
setServiceChooser(org.apache.camel.cloud.ServiceChooser serverChooser)
void
setServiceDiscovery(org.apache.camel.cloud.ServiceDiscovery serverDiscovery)
void
setServiceFilter(org.apache.camel.cloud.ServiceFilter serviceFilter)
-
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
-
-
-
-
Method Detail
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
getServiceDiscovery
public org.apache.camel.cloud.ServiceDiscovery getServiceDiscovery()
- Specified by:
getServiceDiscovery
in interfaceorg.apache.camel.cloud.ServiceDiscoveryAware
-
setServiceDiscovery
public void setServiceDiscovery(org.apache.camel.cloud.ServiceDiscovery serverDiscovery)
- Specified by:
setServiceDiscovery
in interfaceorg.apache.camel.cloud.ServiceDiscoveryAware
-
getServiceChooser
public org.apache.camel.cloud.ServiceChooser getServiceChooser()
- Specified by:
getServiceChooser
in interfaceorg.apache.camel.cloud.ServiceChooserAware
-
setServiceChooser
public void setServiceChooser(org.apache.camel.cloud.ServiceChooser serverChooser)
- Specified by:
setServiceChooser
in interfaceorg.apache.camel.cloud.ServiceChooserAware
-
setServiceFilter
public void setServiceFilter(org.apache.camel.cloud.ServiceFilter serviceFilter)
- Specified by:
setServiceFilter
in interfaceorg.apache.camel.cloud.ServiceFilterAware
-
getServiceFilter
public org.apache.camel.cloud.ServiceFilter getServiceFilter()
- Specified by:
getServiceFilter
in interfaceorg.apache.camel.cloud.ServiceFilterAware
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
-