We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7f57698 commit a9e619fCopy full SHA for a9e619f
tzkt/events/signalr/hub.go
@@ -109,11 +109,11 @@ func (hub *Hub) reconnect() error {
109
log.Warn("reconnecting...")
110
111
if err := hub.Send(newCloseMessage()); err != nil {
112
- return err
+ log.Error(err)
113
}
114
115
if err := hub.conn.Close(); err != nil {
116
117
118
log.Info("connection closed")
119
if err := hub.handshake(); err != nil {
@@ -141,6 +141,8 @@ func (hub *Hub) listen() {
141
case errors.Is(err, ErrTimeout):
142
if err := hub.reconnect(); err != nil {
143
log.Errorf("reconnect: %s", err.Error())
144
+ log.Warn("retry after 5 seconds")
145
+ time.Sleep(time.Second * 5)
146
147
case errors.Is(err, ErrEmptyResponse):
148
default:
0 commit comments