RabbitMQ Client implementation in springboot

	
            org.springframework.boot
            spring-boot-starter-amqp
       

#Rabbitmq configuration
spring.rabbitmq.host=hostUrl
spring.rabbitmq.port = hostPort
spring.rabbitmq.username =username
spring.rabbitmq.password =password
spring.rabbitmq.virtual-host=virtualHost

public class RobbitMqConfig  {
	public final static String publishQName ="publishQueue";
	public final static String consumeQName ="consumeQueue";
	@Bean
	public Jackson2JsonMessageConverter jsonMessageConverter(){
		Jackson2JsonMessageConverter con= new Jackson2JsonMessageConverter();
		return con;
	}
	@Bean
	RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
		RabbitTemplate templete=new RabbitTemplate();
		templete.setExchange("exchange");//Set exchange
		templete.setQueue(publishQName);//Declare queue
		templete.setMessageConverter(jsonMessageConverter());
		templete.setConnectionFactory(connectionFactory);
		return templete;
	}
	@Bean
	SimpleMessageListenerContainer container(ConnectionFactory connectionFactory) {
		SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
		container.setConnectionFactory(connectionFactory);
		container.setQueueNames(consumeQName);
		container.setMessageConverter(jsonMessageConverter());
		container.setMessageListener(consumer());
		return container;
	}
	@Bean MessageListener consumer(){
		return new Consumer();
	}
}

public class RabbitmqTest {
	@Autowired
	private RabbitTemplate rabbitTemplate;
	@Test
	public void test() throws Exception {
		rabbitTemplate.convertAndSend(RobbitMqConfig.publishQName, "RabbitMQ Spring JSON Example");
		System.out.println("Is listener returned ::: "+rabbitTemplate.isReturnListener());
	}
}

@Service
public class Consumer implements MessageListener {
	private final Logger log = LoggerFactory.getLogger(Consumer.class);	
	@Override
	public void onMessage(Message message) {
		String parseMessage=new String(message.getBody());
		log.info("consumer message {}",parseMessage);
	}
}