viruus.zip
forked from
tangled.org/core
Monorepo for Tangled
wip: fix jetstream client
Signed-off-by: Seongmin Lee <git@boltless.me>
boltless.me
+2
-1
+2
-1
jetstream/jetstream.go
+2
-1
jetstream/jetstream.go
···
159
159
j.cancelMu.Unlock()
160
160
161
161
if err := j.client.ConnectAndRead(connCtx, cursor); err != nil {
162
-
l.Error("error reading jetstream", "error", err)
162
+
l.Error("error reading jetstream, retry in 3s", "error", err)
163
163
cancel()
164
+
time.Sleep(3 * time.Second)
164
165
continue
165
166
}
166
167