From 43a78f537842bef31d27fbce4c51deec080ee631 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Dominique=20Eifl=C3=A4nder?=
 <dominique.eiflaender@knecon.com>
Date: Wed, 13 Dec 2023 13:15:01 +0100
Subject: [PATCH] RED-5223: Added RabbitTemplateMultiCustomizer

---
 .../MultiTenancyMessagingConfiguration.java         | 10 +++++++++-
 .../RabbitTemplateMultiCustomizer.java              | 13 +++++++++++++
 2 files changed, 22 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/knecon/fforesight/tenantcommons/RabbitTemplateMultiCustomizer.java

diff --git a/src/main/java/com/knecon/fforesight/tenantcommons/MultiTenancyMessagingConfiguration.java b/src/main/java/com/knecon/fforesight/tenantcommons/MultiTenancyMessagingConfiguration.java
index b402fbe..e177719 100644
--- a/src/main/java/com/knecon/fforesight/tenantcommons/MultiTenancyMessagingConfiguration.java
+++ b/src/main/java/com/knecon/fforesight/tenantcommons/MultiTenancyMessagingConfiguration.java
@@ -37,6 +37,14 @@ public class MultiTenancyMessagingConfiguration {
         return container -> customizers.orderedStream().forEach((customizer) -> customizer.customize(container));
     }
 
+
+    @Bean
+    @Primary
+    public RabbitTemplateCustomizer rabbitTemplateMultiCustomizer(
+            ObjectProvider<RabbitTemplateMultiCustomizer> customizers) {
+        return rabbitTemplate -> customizers.orderedStream().forEach((customizer) -> customizer.customize(rabbitTemplate));
+    }
+
     @Bean
     public MessageConverter producerJackson2MessageConverter() {
         ObjectMapper mapper = new ObjectMapper().findAndRegisterModules();
@@ -46,7 +54,7 @@ public class MultiTenancyMessagingConfiguration {
     }
 
     @Bean
-    public RabbitTemplateCustomizer rabbitTemplatePublishTenantIdHeaderCustomizer(
+    public RabbitTemplateMultiCustomizer rabbitTemplatePublishTenantIdHeaderCustomizer(
             @Qualifier("tenantIdSetterPostProcessor") MessagePostProcessor messagePostProcessor) {
         return template -> template.addBeforePublishPostProcessors(messagePostProcessor);
     }
diff --git a/src/main/java/com/knecon/fforesight/tenantcommons/RabbitTemplateMultiCustomizer.java b/src/main/java/com/knecon/fforesight/tenantcommons/RabbitTemplateMultiCustomizer.java
new file mode 100644
index 0000000..1d262d9
--- /dev/null
+++ b/src/main/java/com/knecon/fforesight/tenantcommons/RabbitTemplateMultiCustomizer.java
@@ -0,0 +1,13 @@
+package com.knecon.fforesight.tenantcommons;
+
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+
+@FunctionalInterface
+public interface RabbitTemplateMultiCustomizer {
+
+    void customize(RabbitTemplate rabbitTemplate);
+
+}
+
+
+