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