Simplify set up of ProjectionNotificationProcessor

Author: Christian Wygoda

driver/sql/projection_notification_processor.go

@@ -33,7 +33,6 @@ func NewBackgroundProcessor(
 	queueBuffer int,
 	logger goengine.Logger,
 	metrics Metrics,
-	retryDelay time.Duration,
 	notificationQueue NotificationQueuer,
 ) (*ProjectionNotificationProcessor, error) {
 	if queueProcessors <= 0 {
@@ -49,7 +48,7 @@ func NewBackgroundProcessor(
 		metrics = NopMetrics
 	}
 	if notificationQueue == nil {
-		notificationQueue = newNotificationQueue(queueBuffer, retryDelay, metrics)
+		notificationQueue = newNotificationQueue(queueBuffer, 0, metrics)
 	}
 
 	return &ProjectionNotificationProcessor{

driver/sql/projection_notification_processor_test.go

@@ -79,8 +79,7 @@ func TestStartProcessor(t *testing.T) {
 
 			bufferSize := 1
 			queueProcessorsCount := 1
-			retryDelay := time.Millisecond * 0
-			processor, err := sql.NewBackgroundProcessor(queueProcessorsCount, bufferSize, nil, nil, retryDelay, nqMock)
+			processor, err := sql.NewBackgroundProcessor(queueProcessorsCount, bufferSize, nil, nil, nqMock)
 			require.NoError(t, err)
 
 			var wg sync.WaitGroup

driver/sql/projector_aggregate.go

@@ -61,7 +61,7 @@ func NewAggregateProjector(
 		e.String("projection", projection.Name())
 	})
 
-	processor, err := NewBackgroundProcessor(10, 32, logger, metrics, retryDelay, nil)
+	processor, err := NewBackgroundProcessor(10, 32, logger, metrics, nil)
 	if err != nil {
 		return nil, err
 	}