public final class AtomixClusterClientService
extends org.apache.camel.impl.cluster.AbstractCamelClusterService<org.apache.camel.component.atomix.cluster.AtomixClusterView>
Constructor and Description |
---|
AtomixClusterClientService() |
AtomixClusterClientService(org.apache.camel.CamelContext camelContext,
AtomixClientConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.component.atomix.cluster.AtomixClusterView |
createView(String namespace) |
protected void |
doStart() |
protected void |
doStop() |
io.atomix.AtomixClient |
getAtomix() |
AtomixClientConfiguration |
getConfiguration() |
String |
getConfigurationUri() |
List<io.atomix.catalyst.transport.Address> |
getNodes() |
Class<? extends io.atomix.catalyst.transport.Transport> |
getTransport() |
boolean |
isEphemeral() |
void |
setAtomix(io.atomix.AtomixClient atomix) |
void |
setConfiguration(AtomixClientConfiguration configuration) |
void |
setConfigurationUri(String configurationUri) |
void |
setEphemeral(boolean ephemeral) |
void |
setNodes(List<io.atomix.catalyst.transport.Address> nodes) |
void |
setNodes(String nodes) |
void |
setTransport(Class<? extends io.atomix.catalyst.transport.Transport> transport) |
getAttributes, getCamelContext, getId, getNamespaces, getOrder, getView, isLeader, releaseView, setAttribute, setAttributes, setCamelContext, setId, setOrder, startView, stopView
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public AtomixClusterClientService()
public AtomixClusterClientService(org.apache.camel.CamelContext camelContext, AtomixClientConfiguration configuration)
public AtomixClientConfiguration getConfiguration()
public void setConfiguration(AtomixClientConfiguration configuration)
public List<io.atomix.catalyst.transport.Address> getNodes()
public void setNodes(List<io.atomix.catalyst.transport.Address> nodes)
public void setNodes(String nodes)
public Class<? extends io.atomix.catalyst.transport.Transport> getTransport()
public void setTransport(Class<? extends io.atomix.catalyst.transport.Transport> transport)
public io.atomix.AtomixClient getAtomix()
public void setAtomix(io.atomix.AtomixClient atomix)
public String getConfigurationUri()
public void setConfigurationUri(String configurationUri)
public boolean isEphemeral()
public void setEphemeral(boolean ephemeral)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.cluster.AbstractCamelClusterService<org.apache.camel.component.atomix.cluster.AtomixClusterView>
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.cluster.AbstractCamelClusterService<org.apache.camel.component.atomix.cluster.AtomixClusterView>
Exception
Apache Camel