Skip notifications if validAfter has not been reached

Author: Sergiu Ghitea

driver/sql/projection_notification_processor.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"runtime"
 	"sync"
+	"time"
 
 	"github.com/hellofresh/goengine"
 	"github.com/pkg/errors"
@@ -116,13 +117,19 @@ func (b *projectionNotificationProcessor) Queue(ctx context.Context, notificatio
 }
 
 func (b *projectionNotificationProcessor) startProcessor(ctx context.Context, handler ProcessHandler) {
+ProcessorLoop:
 	for {
 		select {
 		case <-b.done:
 			return
 		case <-ctx.Done():
 			return
 		case notification := <-b.queue:
+			if notification != nil && notification.ValidAfter.After(time.Now()) {
+				b.queue <- notification
+				continue ProcessorLoop
+			}
+
 			// Execute the notification
 			b.metrics.StartNotificationProcessing(notification)
 			if err := handler(ctx, notification, b.Queue); err != nil {