Merge pull request #27 from uselagoon/feature/disableapiintegration-e…

…nvvar Adds new environment var
uselagoon · Jul 27, 2023 · 6804165 · 6804165
2 parents 4b7e4c3 + 4b359e5
commit 6804165
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 8 deletions.
diff --git a/internal/handler/main.go b/internal/handler/main.go
@@ -295,7 +295,7 @@ func processingIncomingMessageQueueFactory(h *Messaging) func(mq.Message) {
 			// Ack to remove from queue
 			err := message.Ack(false)
 			if err != nil {
-				fmt.Errorf("%s", err.Error())
+				fmt.Printf("Failed to acknowledge message: %s\n", err.Error())
 			}
 		}(message)
 
@@ -376,7 +376,7 @@ func processingIncomingMessageQueueFactory(h *Messaging) func(mq.Message) {
 			}
 			err := message.Reject(false)
 			if err != nil {
-				fmt.Errorf("%s", err.Error())
+				fmt.Printf("Unable to reject payload: %s\n", err.Error())
 			}
 			return
 		}
@@ -417,12 +417,6 @@ func processingIncomingMessageQueueFactory(h *Messaging) func(mq.Message) {
 				}
 			}
 		}
-
-		// Ack to remove from queue
-		err := message.Ack(false)
-		if err != nil {
-			fmt.Errorf("%s", err.Error())
-		}
 	}
 }
 

diff --git a/main.go b/main.go
@@ -92,6 +92,8 @@ func main() {
 	s3Region = getEnv("S3_FILES_REGION", s3Region)
 	filterTransformerFile = getEnv("FILTER_TRANSFORMER_FILE", filterTransformerFile)
 	s3useSSL = getEnvBool("S3_USESSL", s3useSSL)
+	disableAPIIntegration = getEnvBool("INSIGHTS_DISABLE_API_INTEGRATION", disableAPIIntegration)
+	disableS3Upload = getEnvBool("INSIGHTS_DISABLE_S3_UPLOAD", disableS3Upload)
 
 	// configure the backup handler settings
 	broker := handler.RabbitBroker{