Skip to content

Commit a60c0e6

Browse files
committed
Relaxed streaming timers
1 parent fca5a1c commit a60c0e6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/redislabs/demos/redisbank/transactions/BankTransactionForwarder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,10 +45,10 @@ public BankTransactionForwarder(Config config, StringRedisTemplate redis, SimpMe
4545
@Override
4646
public void afterPropertiesSet() throws Exception {
4747
this.container = StreamMessageListenerContainer.create(redis.getConnectionFactory(),
48-
StreamMessageListenerContainerOptions.builder().pollTimeout(Duration.ofMillis(100)).build());
48+
StreamMessageListenerContainerOptions.builder().pollTimeout(Duration.ofMillis(1000)).build());
4949
container.start();
5050
this.subscription = container.receive(StreamOffset.latest(TRANSACTIONS_STREAM), this);
51-
subscription.await(Duration.ofSeconds(2));
51+
subscription.await(Duration.ofSeconds(10));
5252
}
5353

5454
@Override

0 commit comments

Comments
 (0)