my code used lettuce-core access redis streams for MQ
but I listen by this way
if I do like this the grpc server not start , how can I fix it ?
while (true) {
//block on stream for 1 min before retry
List<StreamMessage<String, String>> messages = conn.sync()
.xreadgroup(consumer,
XReadArgs.Builder.count(1500).block(60000),
XReadArgs.StreamOffset.lastConsumed(streamName));
executor.submit(() -> processMessage(messages);
}
my code used lettuce-core access redis streams for MQ but I listen by this way if I do like this the grpc server not start , how can I fix it ?