@ManagedResource(description="Spring Redis based message id repository") public class RedisIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<String>
Constructor and Description |
---|
RedisIdempotentRepository(org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate,
String processorName) |
RedisIdempotentRepository(String processorName) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(String key) |
void |
clear() |
boolean |
confirm(String key) |
boolean |
contains(String key) |
protected void |
doShutdown() |
protected void |
doStart() |
protected void |
doStop() |
String |
getProcessorName() |
static RedisIdempotentRepository |
redisIdempotentRepository(org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate,
String processorName) |
static RedisIdempotentRepository |
redisIdempotentRepository(String processorName) |
boolean |
remove(String key) |
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public RedisIdempotentRepository(org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate, String processorName)
public RedisIdempotentRepository(String processorName)
public static RedisIdempotentRepository redisIdempotentRepository(String processorName)
public static RedisIdempotentRepository redisIdempotentRepository(org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate, String processorName)
@ManagedOperation(description="Adds the key to the store") public boolean add(String key)
add
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedOperation(description="Does the store contain the given key") public boolean contains(String key)
contains
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedOperation(description="Remove the key from the store") public boolean remove(String key)
remove
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedOperation(description="Clear the store") public void clear()
clear
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedAttribute(description="The processor name") public String getProcessorName()
public boolean confirm(String key)
confirm
in interface org.apache.camel.spi.IdempotentRepository<String>
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
Apache Camel