public class HazelcastIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<String>
Constructor and Description |
---|
HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance) |
HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance,
String repositoryName) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(String key) |
void |
clear() |
boolean |
confirm(String key) |
boolean |
contains(String key) |
protected void |
doStart() |
protected void |
doStop() |
String |
getRepositoryName() |
boolean |
remove(String key) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance)
public HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance, String repositoryName)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
public boolean add(String key)
add
in interface org.apache.camel.spi.IdempotentRepository<String>
public boolean confirm(String key)
confirm
in interface org.apache.camel.spi.IdempotentRepository<String>
public boolean contains(String key)
contains
in interface org.apache.camel.spi.IdempotentRepository<String>
public boolean remove(String key)
remove
in interface org.apache.camel.spi.IdempotentRepository<String>
public void clear()
clear
in interface org.apache.camel.spi.IdempotentRepository<String>
public String getRepositoryName()
Apache Camel