test reconnects

jakubwro · Oct 2, 2023 · 32b3aeb · 32b3aeb
1 parent b20a291
commit 32b3aeb
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/test/connection.jl b/test/connection.jl
@@ -60,3 +60,18 @@ end
     unsubscribe(sub)
     sleep(0.1)
 end
+
+@testset "Should reconnect on malformed msg" begin
+    nc = NATS.connect()
+    con_msg = NATS.from_kwargs(NATS.Connect, NATS.DEFAULT_CONNECT_ARGS, (protocol=100,))
+    NATS.send(nc, con_msg)
+    sleep(5)
+    @test nc.status == NATS.CONNECTED
+end
+
+@testset "Should reconnect on outbox closed" begin
+    nc = NATS.connect()
+    close(nc.outbox)
+    sleep(5)
+    @test nc.status == NATS.CONNECTED
+end