Skip to content

Commit

Permalink
chore(dependencies): Reverting Spring Boot 2.2 upgrade (#735)
Browse files Browse the repository at this point in the history
Revert "chore(dependencies): Upgrade Spring Boot to 2.2.1 (#702)"
This reverts commit a8d0c89
  • Loading branch information
Pierre Delagrave authored and Matt Duftler committed Jan 7, 2020
1 parent 6e6f748 commit e275415
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import java.util.zip.CRC32;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import redis.clients.jedis.params.SetParams;

/** Shared cache of received and handled pubsub messages to synchronize clients. */
@Slf4j
Expand All @@ -42,6 +41,8 @@ public class PubsubMessageHandler {
private final Registry registry;
private final List<EventCreator> eventCreators;

private static final String SET_IF_NOT_EXIST = "NX";
private static final String SET_EXPIRE_TIME_SECONDS = "EX";
private static final String SUCCESS = "OK";

@Service
Expand Down Expand Up @@ -130,7 +131,11 @@ private Boolean acquireMessageLock(
redisClientDelegate.withCommandsClient(
c -> {
return c.set(
messageKey, identifier, SetParams.setParams().nx().ex(ackDeadlineSeconds));
messageKey,
identifier,
SET_IF_NOT_EXIST,
SET_EXPIRE_TIME_SECONDS,
ackDeadlineSeconds);
});
return SUCCESS.equals(response);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import com.netflix.spinnaker.kork.jedis.EmbeddedRedis
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import redis.clients.jedis.Jedis
import redis.clients.jedis.util.Pool
import redis.clients.util.Pool

@Configuration
class EmbeddedRedisConfiguration {
Expand Down
4 changes: 2 additions & 2 deletions gradle.properties
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#Tue Dec 17 19:07:11 UTC 2019
fiatVersion=1.11.0
fiatVersion=1.12.0
enablePublishing=false
korkVersion=7.4.0
spinnakerGradleVersion=7.0.1
korkVersion=7.3.0
org.gradle.parallel=true

0 comments on commit e275415

Please sign in to comment.