this repo has no description
fix(receiver): don't log "timeouts"
seems like it's just polling behavior? need to do something other than
that infinite for{} anyways
+1
-1
+1
-1
server/main.go
+1
-1
server/main.go
···
150
150
msgs, err := consumerSub.Fetch(10, nats.MaxWait(5*time.Second))
151
151
if err != nil {
152
152
if err == nats.ErrTimeout {
153
-
ll.WarnDisplay("Timed out fetching messages", err)
153
+
// ok
154
154
} else if err == nats.ErrBadSubscription {
155
155
ll.WarnDisplay("Subscription is not valid anymore, trying to reconnect to consumer", err)
156
156
consumerSub, err = js.PullSubscribe(notella.SubjectName, "NotellaConsumer")