| Package | Description |
|---|---|
| org.apache.camel.cluster |
Camel Cluster support
|
| org.apache.camel.component.file.cluster | |
| org.apache.camel.impl.cluster |
Base classes and implementation for Camel Cluster
|
| org.apache.camel.management |
Camel management
|
| org.apache.camel.management.mbean |
Camel management JMX MBeans
|
| org.apache.camel.spi |
Service Provider Interfaces used by the Camel runtime which are plugin strategies.
|
| Modifier and Type | Method and Description |
|---|---|
default <T extends CamelClusterService> |
CamelClusterService.unwrap(Class<T> clazz)
Access the underlying concrete CamelClusterService implementation to
provide access to further features.
|
| Modifier and Type | Method and Description |
|---|---|
CamelClusterService |
CamelClusterView.getClusterService() |
| Modifier and Type | Method and Description |
|---|---|
Optional<CamelClusterService> |
CamelClusterService.Selector.select(Collection<CamelClusterService> services)
Select a specific CamelClusterService instance among a collection.
|
| Modifier and Type | Method and Description |
|---|---|
Optional<CamelClusterService> |
CamelClusterService.Selector.select(Collection<CamelClusterService> services)
Select a specific CamelClusterService instance among a collection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileLockClusterService |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCamelClusterService<T extends CamelClusterView> |
| Modifier and Type | Method and Description |
|---|---|
CamelClusterService |
ClusteredRouteController.getClusterService() |
CamelClusterService |
AbstractCamelClusterView.getClusterService() |
static CamelClusterService |
ClusterServiceHelper.mandatoryLookupService(CamelContext context) |
static CamelClusterService |
ClusterServiceHelper.mandatoryLookupService(CamelContext context,
CamelClusterService.Selector selector) |
| Modifier and Type | Method and Description |
|---|---|
static Optional<CamelClusterService> |
ClusterServiceHelper.lookupService(CamelContext context) |
static Optional<CamelClusterService> |
ClusterServiceHelper.lookupService(CamelContext context,
CamelClusterService.Selector selector) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectSingle.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectFirst.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByOrder.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByType.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByAttribute.select(Collection<CamelClusterService> services) |
| Modifier and Type | Method and Description |
|---|---|
static ClusteredRoutePolicyFactory |
ClusteredRoutePolicyFactory.forNamespace(CamelClusterService clusterService,
String namespace) |
static ClusteredRoutePolicy |
ClusteredRoutePolicy.forNamespace(CamelClusterService service,
String namespace) |
void |
ClusteredRouteController.setClusterService(CamelClusterService clusterService)
Set the cluster service to use.
|
| Modifier and Type | Method and Description |
|---|---|
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectSingle.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectFirst.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByOrder.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByType.select(Collection<CamelClusterService> services) |
Optional<CamelClusterService> |
ClusterServiceSelectors.SelectByAttribute.select(Collection<CamelClusterService> services) |
static CamelClusterService.Selector |
ClusterServiceSelectors.type(Class<? extends CamelClusterService> type) |
| Constructor and Description |
|---|
AbstractCamelClusterView(CamelClusterService cluster,
String namespace) |
ClusteredRoutePolicyFactory(CamelClusterService clusterService,
String viewName) |
| Constructor and Description |
|---|
SelectByType(Class<? extends CamelClusterService> type) |
| Modifier and Type | Method and Description |
|---|---|
Object |
DefaultManagementObjectStrategy.getManagedObjectForClusterService(CamelContext context,
CamelClusterService service) |
ObjectName |
DefaultManagementNamingStrategy.getObjectNameForClusterService(CamelContext context,
CamelClusterService service) |
| Modifier and Type | Method and Description |
|---|---|
CamelClusterService |
ManagedClusterService.getService() |
| Constructor and Description |
|---|
ManagedClusterService(CamelContext context,
CamelClusterService service) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ManagementObjectStrategy.getManagedObjectForClusterService(CamelContext context,
CamelClusterService service) |
ObjectName |
ManagementNamingStrategy.getObjectNameForClusterService(CamelContext context,
CamelClusterService service) |
Apache Camel