Closed
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
Environment
withEnvironmentBuilder.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