From 4b18f02316b5a9990847e17cc320fb69ce3fc589 Mon Sep 17 00:00:00 2001 From: Orne Brocaar Date: Tue, 6 Jul 2021 11:30:50 +0100 Subject: [PATCH] Increment initial ts for multicast enqueue. --- internal/downlink/multicast/enqueue.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/downlink/multicast/enqueue.go b/internal/downlink/multicast/enqueue.go index 7766df41..8dcc7241 100644 --- a/internal/downlink/multicast/enqueue.go +++ b/internal/downlink/multicast/enqueue.go @@ -58,6 +58,8 @@ func EnqueueQueueItem(ctx context.Context, db sqlx.Ext, qi storage.MulticastQueu if ts.IsZero() { ts = time.Now() + } else { + ts = ts.Add(multicastGatewayDelay) } for _, gatewayID := range gatewayIDs {