File tree Expand file tree Collapse file tree 2 files changed +7
-5
lines changed
src/main/java/com/rabbitmq/stream Expand file tree Collapse file tree 2 files changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -57,7 +57,7 @@ static EnvironmentBuilder builder() {
57
57
/**
58
58
* Delete a stream
59
59
*
60
- * @param stream
60
+ * @param stream the stream to delete
61
61
*/
62
62
void deleteStream (String stream );
63
63
@@ -66,7 +66,7 @@ static EnvironmentBuilder builder() {
66
66
*
67
67
* <p>Requires RabbitMQ 3.11 or more.
68
68
*
69
- * @param stream
69
+ * @param stream the stream to get statistics from
70
70
* @return statistics on the stream
71
71
* @throws UnsupportedOperationException if the broker does not support this command
72
72
*/
@@ -75,7 +75,7 @@ static EnvironmentBuilder builder() {
75
75
/**
76
76
* Return whether a stream exists or not.
77
77
*
78
- * @param stream
78
+ * @param stream the stream to check the existence
79
79
* @return true if stream exists, false if it does not exist
80
80
* @throws StreamException if response code is different from {@link Constants#RESPONSE_CODE_OK}
81
81
* or {@link Constants#RESPONSE_CODE_STREAM_DOES_NOT_EXIST}
Original file line number Diff line number Diff line change @@ -216,8 +216,10 @@ class StreamEnvironment implements Environment {
216
216
lastException = e ;
217
217
}
218
218
}
219
- if (this .locators .stream ().allMatch (l -> l .isNotSet ())) {
220
- throw lastException ;
219
+ if (this .locators .stream ().allMatch (Locator ::isNotSet )) {
220
+ throw lastException == null
221
+ ? new StreamException ("Not locator available" )
222
+ : lastException ;
221
223
} else {
222
224
this .locators .forEach (
223
225
l -> {
You can’t perform that action at this time.
0 commit comments