Define producer for SQS consumer so it can also queue new events from event handlers

queues/sqs/consumer.go

@@ -80,6 +80,10 @@ func (consumer consumer) WithAuditor(auditor audit.Auditor) queues.Consumer {
 }
 
 func (consumer consumer) Run() {
+	//create producer so event handler can queue new events (e.g. retries...)
+	consumer.Debugf("Using SQS queue producer for async events ...")
+	consumer.Service = consumer.Service.WithProducer(NewProducer(consumer.requestIDHeaderKey))
+
 	lambda.Start(consumer.Handler)
 }
 

service/service.go

@@ -27,6 +27,7 @@ func New() Service {
 		env = "dev"
 	}
 	return service{
+		Producer:       nil,
 		Logger:         logger.New().WithFields(map[string]interface{}{"env": env}),
 		IErrorReporter: DoNotReportErrors{},
 		Auditor:        audit.None(),
@@ -78,6 +79,7 @@ func (s service) WithStarter(name string, starter IStarter) Service {
 func (s service) WithProducer(producer Producer) Service {
 	if producer != nil {
 		s.Producer = producer
+		s.Infof("Producer = (%T)%v", producer, producer)
 	}
 	return s
 }