+ add overloaded delete/watch operation for single key invocations

This commit is contained in:
Costin Leau
2011-03-01 17:43:16 +02:00
parent b9a6ae7b71
commit 2e53b178f0
2 changed files with 30 additions and 0 deletions

View File

@@ -65,6 +65,8 @@ public interface RedisOperations<K, V> {
Boolean hasKey(K key);
void delete(K key);
void delete(Collection<K> key);
DataType type(K key);
@@ -85,6 +87,8 @@ public interface RedisOperations<K, V> {
Long getExpire(K key);
void watch(K keys);
void watch(Collection<K> keys);
void unwatch();

View File

@@ -575,6 +575,19 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
});
}
@Override
public void delete(K key) {
final byte[] rawKey = rawKey(key);
execute(new RedisCallback<Object>() {
@Override
public Object doInRedis(RedisConnection connection) {
connection.del(rawKey);
return null;
}
}, true);
}
@Override
public void delete(Collection<K> keys) {
final byte[][] rawKeys = rawKeys(keys);
@@ -787,6 +800,19 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
}, true);
}
@Override
public void watch(K key) {
final byte[] rawKey = rawKey(key);
execute(new RedisCallback<Object>() {
@Override
public Object doInRedis(RedisConnection connection) {
connection.watch(rawKey);
return null;
}
}, true);
}
@Override
public void watch(Collection<K> keys) {
final byte[][] rawKeys = rawKeys(keys);