Make Client#streamStats(String) public

acogoluegnes · acogoluegnes · commit cfebbb230ee2 · 2025-12-15T15:56:49.000+01:00
diff --git a/src/main/java/com/rabbitmq/stream/impl/Client.java b/src/main/java/com/rabbitmq/stream/impl/Client.java
@@ -1749,7 +1749,7 @@ List<FrameHandlerInfo> exchangeCommandVersions() {
     }
   }
 
-  StreamStatsResponse streamStats(String stream) {
+  public StreamStatsResponse streamStats(String stream) {
     this.streamStatsCommandVersionsCheck.run();
     if (stream == null) {
       throw new IllegalArgumentException("stream must not be null");
@@ -2346,7 +2346,7 @@ public long getSequence() {
     }
   }
 
-  static class StreamStatsResponse extends Response {
+  public static class StreamStatsResponse extends Response {
 
     private final Map<String, Long> info;
 

Original file line number	Diff line number	Diff line change
`@@ -1749,7 +1749,7 @@ List<FrameHandlerInfo> exchangeCommandVersions() {`
`1749`	`1749`	`}`
`1750`	`1750`	`}`
`1751`	`1751`
`1752`		`- StreamStatsResponse streamStats(String stream) {`
	`1752`	`+ public StreamStatsResponse streamStats(String stream) {`
`1753`	`1753`	`this.streamStatsCommandVersionsCheck.run();`
`1754`	`1754`	`if (stream == null) {`
`1755`	`1755`	`throw new IllegalArgumentException("stream must not be null");`
`@@ -2346,7 +2346,7 @@ public long getSequence() {`
`2346`	`2346`	`}`
`2347`	`2347`	`}`
`2348`	`2348`
`2349`		`- static class StreamStatsResponse extends Response {`
	`2349`	`+ public static class StreamStatsResponse extends Response {`
`2350`	`2350`
`2351`	`2351`	`private final Map<String, Long> info;`
`2352`	`2352`