Rabbittemplate config

src/main/java/com/knecon/fforesight/tenantcommons/MultiTenancyMessagingConfiguration.java

@@ -3,17 +3,40 @@ package com.knecon.fforesight.tenantcommons;
 import static com.knecon.fforesight.tenantcommons.ForwardTenantInterceptor.TENANT_HEADER_NAME;
 
 import org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+
 @Configuration
 @ConditionalOnClass(RabbitTemplate.class)
 public class MultiTenancyMessagingConfiguration {
 
+    @Bean
+    @ConditionalOnBean(ConnectionFactory.class)
+    public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) {
+
+        final var rabbitTemplate = new RabbitTemplate(connectionFactory);
+        rabbitTemplate.setMessageConverter(producerJackson2MessageConverter());
+        return rabbitTemplate;
+    }
+
+
+    @Bean
+    public Jackson2JsonMessageConverter producerJackson2MessageConverter() {
+
+        ObjectMapper mapper = new ObjectMapper().findAndRegisterModules();
+
+        return new Jackson2JsonMessageConverter(mapper);
+    }
+
     @Bean
     public static BeanPostProcessor multitenancyBeanPostProcessor() {