Skip to content

Commit a1b1c77

Browse files
committed
Add more context to log message
1 parent 7623def commit a1b1c77

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/stream/impl/ConsumersCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -886,7 +886,7 @@ private void recoverSubscription(List<Broker> candidates, SubscriptionTracker tr
886886
() -> findBrokersForStream(tracker.stream),
887887
ex -> !(ex instanceof StreamDoesNotExistException),
888888
environment.recoveryBackOffDelayPolicy(),
889-
"Candidate lookup to consume from '%s'",
889+
"Candidate lookup to consume from '%s' (subscription recovery)",
890890
tracker.stream);
891891
} catch (Exception e) {
892892
LOGGER.warn("Error while re-assigning subscription from stream {}", tracker.stream, e);

0 commit comments

Comments
 (0)