Enforce lazy initialization on queryStreamStats

Fixes #368

Author: acogoluegnes

Diff for: src/main/java/com/rabbitmq/stream/impl/StreamEnvironment.java

@@ -480,6 +480,7 @@ public void deleteStream(String stream) {
   @Override
   public StreamStats queryStreamStats(String stream) {
     checkNotClosed();
+    this.maybeInitializeLocator();
     StreamStatsResponse response =
         locatorOperation(
             Utils.namedFunction(

Diff for: src/test/java/com/rabbitmq/stream/impl/StreamEnvironmentTest.java

@@ -552,10 +552,12 @@ void createPublishConsumeDelete(boolean lazyInit, TestInfo info) {
     }
   }
 
-  @Test
+  @ParameterizedTest
+  @ValueSource(booleans = {true, false})
   @BrokerVersionAtLeast(BrokerVersion.RABBITMQ_3_11)
-  void queryStreamStatsShouldReturnFirstOffsetAndCommittedOffset() throws Exception {
-    try (Environment env = environmentBuilder.build()) {
+  void queryStreamStatsShouldReturnFirstOffsetAndCommittedOffset(boolean lazyInit)
+      throws Exception {
+    try (Environment env = environmentBuilder.lazyInitialization(lazyInit).build()) {
       StreamStats stats = env.queryStreamStats(stream);
       assertThatThrownBy(() -> stats.firstOffset()).isInstanceOf(NoOffsetException.class);
       assertThatThrownBy(() -> stats.committedChunkId()).isInstanceOf(NoOffsetException.class);