Renaming parameter

elastic · Apr 20, 2020 · 5ff7219 · 5ff7219
1 parent 041922b
commit 5ff7219
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/libbeat/publisher/pipeline/controller.go b/libbeat/publisher/pipeline/controller.go
@@ -64,18 +64,18 @@ func newOutputController(
 	beat beat.Info,
 	monitors Monitors,
 	observer outputObserver,
-	b queue.Queue,
+	queue queue.Queue,
 ) *outputController {
 	c := &outputController{
 		beat:      beat,
 		monitors:  monitors,
 		observer:  observer,
-		queue:     b,
+		queue:     queue,
 		workQueue: makeWorkQueue(),
 	}
 
 	ctx := &batchContext{}
-	c.consumer = newEventConsumer(monitors.Logger, b, ctx)
+	c.consumer = newEventConsumer(monitors.Logger, queue, ctx)
 	c.retryer = newRetryer(monitors.Logger, observer, c.workQueue, c.consumer)
 	ctx.observer = observer
 	ctx.retryer = c.retryer