package com.springbootdev.examples.producer.config; | |
import org.springframework.amqp.rabbit.connection.ConnectionFactory; | |
import org.springframework.amqp.rabbit.core.RabbitTemplate; | |
import org.springframework.amqp.support.converter.*; | |
import org.springframework.context.annotation.Bean; | |
import org.springframework.context.annotation.Configuration; | |
@Configuration | |
public class RabbitMqConfig | |
{ | |
@Bean | |
public MessageConverter messageConverter() | |
{ | |
return new Jackson2JsonMessageConverter(); | |
} | |
@Bean | |
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) { | |
RabbitTemplate template = new RabbitTemplate(connectionFactory); | |
template.setMessageConverter(messageConverter()); | |
return template; | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment