public final class AtomixClusterService
extends org.apache.camel.impl.cluster.AbstractCamelClusterService<org.apache.camel.component.atomix.cluster.AtomixClusterView>
Constructor and Description |
---|
AtomixClusterService() |
AtomixClusterService(org.apache.camel.CamelContext camelContext,
io.atomix.catalyst.transport.Address address,
AtomixClusterConfiguration 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.catalyst.transport.Address |
getAddress() |
io.atomix.AtomixReplica |
getAtomix() |
AtomixClusterConfiguration |
getConfiguration() |
String |
getConfigurationUri() |
List<io.atomix.catalyst.transport.Address> |
getNodes() |
io.atomix.copycat.server.storage.StorageLevel |
getStorageLevel() |
String |
getStoragePath() |
Class<? extends io.atomix.catalyst.transport.Transport> |
getTransport() |
boolean |
isEphemeral() |
void |
setAddress(io.atomix.catalyst.transport.Address address) |
void |
setAddress(String address) |
void |
setAtomix(io.atomix.AtomixReplica atomix) |
void |
setConfiguration(AtomixClusterConfiguration configuration) |
void |
setConfigurationUri(String configurationUri) |
void |
setEphemeral(boolean ephemeral) |
void |
setNodes(List<io.atomix.catalyst.transport.Address> nodes) |
void |
setNodes(String nodes) |
void |
setStorageLevel(io.atomix.copycat.server.storage.StorageLevel storageLevel) |
void |
setStoragePath(String storagePath) |
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 AtomixClusterService()
public AtomixClusterService(org.apache.camel.CamelContext camelContext, io.atomix.catalyst.transport.Address address, AtomixClusterConfiguration configuration)
public io.atomix.catalyst.transport.Address getAddress()
public void setAddress(String address)
public void setAddress(io.atomix.catalyst.transport.Address address)
public AtomixClusterConfiguration getConfiguration()
public void setConfiguration(AtomixClusterConfiguration configuration)
public String getStoragePath()
public void setStoragePath(String storagePath)
public io.atomix.copycat.server.storage.StorageLevel getStorageLevel()
public List<io.atomix.catalyst.transport.Address> getNodes()
public void setNodes(List<io.atomix.catalyst.transport.Address> nodes)
public void setStorageLevel(io.atomix.copycat.server.storage.StorageLevel storageLevel)
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.AtomixReplica getAtomix()
public void setAtomix(io.atomix.AtomixReplica 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