diff --git a/exporter/exporterhelper/internal/base_exporter.go b/exporter/exporterhelper/internal/base_exporter.go index e95f8e3d956..4a730e20aab 100644 --- a/exporter/exporterhelper/internal/base_exporter.go +++ b/exporter/exporterhelper/internal/base_exporter.go @@ -110,7 +110,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe q := be.queueFactory( context.Background(), exporterqueue.Settings{ - Signal: be.Signal, + Signal: signal, ExporterSettings: be.Set, }, be.queueCfg)