We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bd74f95 commit 4d24d74Copy full SHA for 4d24d74
src/main/java/io/axoniq/axonserver/connector/event/impl/PersistentStreamImpl.java
@@ -125,6 +125,11 @@ public void openConnection(InitializationProperties initializationProperties) {
125
outboundStreamHolder.get().onNext(StreamRequest.newBuilder().setOpen(openRequest.build()).build());
126
}
127
128
+ /**
129
+ * Close this stream and signal downstream consumer that the stream is closed "erroneously" in order to trigger
130
+ * reconnect mechanisms. This is to ensure that consumers of this stream can distinguish between regularly closed
131
+ * streams, and those closed with the intent to re-establish a connection.
132
+ */
133
public void triggerReconnect() {
134
// first, close gracefully
135
close();
0 commit comments