package com.fjhx.rabbitmq.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.fjhx.rabbitmq.RabbitMQProducer;
import com.fjhx.rabbitmq.SdRabbitMQProducer;
import com.fjhx.rabbitmq.service.RabbitmqService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @Description:
 * @ClassName: RabbitmqServiceImpl
 * @Author: linqt
 * @Date: 2022/3/28 15:16
 * @Version: 1.0
 */
@Service
public class RabbitmqServiceImpl implements RabbitmqService {

    @Autowired
    private RabbitMQProducer rabbitMQProducer;

    @Autowired
    private SdRabbitMQProducer sdRabbitMQProducer;

    /**
     * 发送消息
     *
     * @param jsonObject
     */
    @Override
    public void send(JSONObject jsonObject) {
        rabbitMQProducer.send(jsonObject);
    }

    /**
     * 发送消息
     *
     * @param jsonObject
     */
    @Override
    public void sdSend(JSONObject jsonObject) {
        sdRabbitMQProducer.send(jsonObject);
    }
}