Skip to content

Commit b6390fb

Browse files
committed
Little cleaning
1 parent 0f89d84 commit b6390fb

File tree

2 files changed

+4
-9
lines changed

2 files changed

+4
-9
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
<modelVersion>4.0.0</modelVersion>
33
<groupId>fi.hsl</groupId>
44
<artifactId>transitdata-common</artifactId>
5-
<version>2.0.3-RC7</version>
5+
<version>2.0.3-RC9</version>
66
<packaging>jar</packaging>
77
<name>Common utilities for Transitdata projects</name>
88
<properties>

src/main/java/fi/hsl/common/pulsar/PulsarApplication.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -93,14 +93,9 @@ public PulsarApplicationContext initialize(@NotNull Config config) throws Except
9393
}
9494

9595
if (config.getBoolean("redis.enabled")) {
96-
int connTimeOutSecs = 2;
97-
if (config.hasPath("redis.connTimeOutSecs")) {
98-
connTimeOutSecs = config.getInt("redis.connTimeOutSecs");
99-
}
10096
jedis = createRedisClient(
10197
config.getString("redis.host"),
102-
config.getInt("redis.port"),
103-
connTimeOutSecs);
98+
config.getInt("redis.port"));
10499
}
105100

106101
if (config.getBoolean("health.enabled")) {
@@ -159,8 +154,8 @@ public PulsarApplicationContext initialize(@NotNull Config config) throws Except
159154
}
160155

161156
@NotNull
162-
protected Jedis createRedisClient(@NotNull String redisHost, int port, int connTimeOutSecs) {
163-
log.info("Connecting to Redis at " + redisHost + ":" + port + " with connection timeout of (s): "+ connTimeOutSecs);
157+
protected Jedis createRedisClient(@NotNull String redisHost, int port) {
158+
log.info("Connecting to Redis at " + redisHost + ":" + port);
164159

165160
//Construct a Token Credential from Identity library, e.g. DefaultAzureCredential / ClientSecretCredential / Client CertificateCredential / ManagedIdentityCredential etc.
166161
DefaultAzureCredential defaultAzureCredential = new DefaultAzureCredentialBuilder().build();

0 commit comments

Comments
 (0)