@ManagedResource(description="Spring Redis based message id repository") public class RedisStringIdempotentRepository extends RedisIdempotentRepository
Constructor and Description |
---|
RedisStringIdempotentRepository(org.springframework.data.redis.core.RedisTemplate<String,String> redisTemplate,
String processorName) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(String key) |
void |
clear() |
boolean |
contains(String key) |
protected String |
createRedisKey(String key) |
long |
getExpiry() |
boolean |
remove(String key) |
void |
setExpiry(long expiry)
Expire all newly added items after the given number of seconds (0 means never expire)
|
confirm, doShutdown, doStart, doStop, getProcessorName, redisIdempotentRepository, redisIdempotentRepository
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
@ManagedOperation(description="Does the store contain the given key") public boolean contains(String key)
contains
in interface org.apache.camel.spi.IdempotentRepository<String>
contains
in class RedisIdempotentRepository
@ManagedOperation(description="Adds the key to the store") public boolean add(String key)
add
in interface org.apache.camel.spi.IdempotentRepository<String>
add
in class RedisIdempotentRepository
@ManagedOperation(description="Remove the key from the store") public boolean remove(String key)
remove
in interface org.apache.camel.spi.IdempotentRepository<String>
remove
in class RedisIdempotentRepository
@ManagedOperation(description="Clear the store") public void clear()
clear
in interface org.apache.camel.spi.IdempotentRepository<String>
clear
in class RedisIdempotentRepository
public long getExpiry()
public void setExpiry(long expiry)
Apache Camel