RabbitMQSender.java

package com.sma.rabbitmq.service;

import com.sma.rabbitmq.model.Category;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

/**
 * Author: Mak Sophea
 * Date: 07/31/2020
 */
@Service
@Slf4j
public class RabbitMQSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    @Value("${backend.rabbitmq.exchange}")
    private String exchange;

    @Value("${backend.rabbitmq.routingkey}")
    private String routingkey;

    public void send(Category category) {
        rabbitTemplate.convertAndSend(exchange, routingkey, category);
        log.info("Send msg = {} ", category);

    }
}