-
Couldn't load subscription status.
- Fork 16
Closed
Labels
bugSomething isn't workingSomething isn't working
Milestone
Description
Describe the bug
When Streams Environment is used with lazy initialization, calling queryStreamStats() fails with
com.rabbitmq.stream.impl.StreamEnvironment$LocatorNotAvailableException: Locator not available
at com.rabbitmq.stream.impl.StreamEnvironment.locatorOperation(StreamEnvironment.java:738)
at com.rabbitmq.stream.impl.StreamEnvironment.locatorOperation(StreamEnvironment.java:692)
at com.rabbitmq.stream.impl.StreamEnvironment.queryStreamStats(StreamEnvironment.java:484)
stream-client version is 0.10.0
Reproduction steps
- Create
EnvironmentwithEnvironmentBuilder.lazyInitialization(true) - Call
streamsEnvironment.queryStreamStats("abc")as the first call - Catch the
LocatorNotAvailableException
Expected behavior
A StreamStats is returned or a StreamDoesNotExistException is thrown.
Additional context
No response
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working