From b221d43f92cdf4f39b2181546be838ec7c104899 Mon Sep 17 00:00:00 2001 From: Atridad Lahiji Date: Wed, 17 Apr 2024 15:29:29 -0600 Subject: [PATCH] This time for sure --- lib/pubsub/adapters/localpubsub.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/lib/pubsub/adapters/localpubsub.go b/lib/pubsub/adapters/localpubsub.go index 0cffe7c..7304c28 100644 --- a/lib/pubsub/adapters/localpubsub.go +++ b/lib/pubsub/adapters/localpubsub.go @@ -82,9 +82,6 @@ func (m *LocalPubSubMessage) ReceiveMessage(ctx context.Context) (*pubsub.Messag // A message has been received. Send it to the client. lib.LogInfo.Printf("\n[PUBSUB/LOCAL] Received message: %s\n", msg.Payload) return &msg, nil - case <-time.After(30 * time.Second): - // No message has been received for 30 seconds. Send a keep-alive message. - return &pubsub.Message{Payload: "keep-alive"}, nil } } }