Allow retries on connect

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2022-07-06 20:54:13 -07:00
parent 69f522cb9f
commit 05e8d82c50

View File

@@ -5973,7 +5973,7 @@ func TestMQTTSessionNotDeletedOnDeleteConsumerError(t *testing.T) {
nc, js := jsClientConnect(t, s1)
defer nc.Close()
mc, r := testMQTTConnect(t, &mqttConnInfo{cleanSess: true}, o.MQTT.Host, o.MQTT.Port)
mc, r := testMQTTConnectRetry(t, &mqttConnInfo{cleanSess: true}, o.MQTT.Host, o.MQTT.Port, 5)
defer mc.Close()
testMQTTCheckConnAck(t, r, mqttConnAckRCConnectionAccepted, false)