Using redis spring 2 features

lukas-krecan · lukas-krecan · commit 94100c0bbfe8 · 2018-06-04T09:14:21.000+02:00
diff --git a/providers/redis/shedlock-provider-redis-spring/src/main/java/net/javacrumbs/shedlock/provider/redis/spring/RedisLockProvider.java b/providers/redis/shedlock-provider-redis-spring/src/main/java/net/javacrumbs/shedlock/provider/redis/spring/RedisLockProvider.java
@@ -53,13 +53,12 @@ public RedisLockProvider(RedisConnectionFactory redisConn, String environment) {
 
     @Override
     public Optional<SimpleLock> lock(LockConfiguration lockConfiguration) {
-
         String key = buildKey(lockConfiguration.getName(), this.environment);
         RedisConnection redisConnection = null;
         try {
             redisConnection = redisConnectionFactory.getConnection();
-            if (redisConnection.setNX(key.getBytes(), buildValue())) {
-                redisConnection.pExpire(key.getBytes(), getMsUntil(lockConfiguration.getLockAtMostUntil()));
+            Expiration expiration = getExpiration(lockConfiguration.getLockAtMostUntil());
+            if (redisConnection.set(key.getBytes(), buildValue(), expiration, SetOption.SET_IF_ABSENT)) {
                 return Optional.of(new RedisLock(key, redisConnectionFactory, lockConfiguration));
             } else {
                 return Optional.empty();
