Skip to content

Commit 9877dcf

Browse files
authored
Merge pull request #1462 from OSGP/feature/throttling-service
Configurable subscription settings
2 parents 205555f + f84af7f commit 9877dcf

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

osgp/platform/osgp-throttling-service/src/main/java/org/opensmartgridplatform/throttling/config/RedisConfig.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,12 @@ public class RedisConfig {
6161
@Value("${redis.connection.pool-size:64}")
6262
private int redisConnectionPoolSize;
6363

64+
@Value("${redis.subscription.connection.pool-size:50}")
65+
private int redisSubscriptionConnectionPoolSize;
66+
67+
@Value("${redis.subscriptions.per.connection:5}")
68+
private int redisSubscriptionsPerConnection;
69+
6470
@Bean(destroyMethod = "shutdown")
6571
public RedissonClient redissonClient(final Config redissonConfig) {
6672
this.installJCAProvider();
@@ -75,6 +81,8 @@ public Config redissonConfig() throws IOException {
7581
singleServerConfig.setPassword(this.password.isEmpty() ? null : this.password);
7682
singleServerConfig.setSslEnableEndpointIdentification(false);
7783
singleServerConfig.setConnectionPoolSize(this.redisConnectionPoolSize);
84+
singleServerConfig.setSubscriptionConnectionPoolSize(this.redisSubscriptionConnectionPoolSize);
85+
singleServerConfig.setSubscriptionsPerConnection(this.redisSubscriptionsPerConnection);
7886

7987
if (this.useSsl) {
8088
singleServerConfig.setAddress(String.format("rediss://%s:%d", this.host, this.port));

osgp/platform/osgp-throttling-service/src/main/resources/osgp-throttling-service.properties

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,3 +50,5 @@ redis.ssl.truststore.password=
5050
redis.password=
5151
redis.protocol=TLSv1.2
5252
redis.connection.pool-size=64
53+
redis.subscription.connection.pool-size=50
54+
redis.subscriptions.per.connection=5

0 commit comments

Comments
 (0)