Skip to content
This repository was archived by the owner on Feb 17, 2025. It is now read-only.

Commit 8b4c6b3

Browse files
Fix connected flag not being set to false. Closes #53
1 parent d08c5e4 commit 8b4c6b3

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

inspector-axon/src/main/java/io/axoniq/inspector/client/RSocketInspectorClient.kt

+3
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,9 @@ class RSocketInspectorClient(
133133
val client = TcpClient.create()
134134
.host(properties.host)
135135
.port(properties.port)
136+
.doOnDisconnected {
137+
connected = false
138+
}
136139
return if (properties.secure) {
137140
return client.secure()
138141
} else client

0 commit comments

Comments
 (0)