package com.zt.common.message.producer;

import com.zt.common.message.model.Message;
import com.zt.common.message.model.MessageSendException;

import java.util.List;

/**
 * 消息发送提供者
 *
 * @author jeff
 */
public interface MessageProducer {

    /**
     * 发送到队列中
     *
     * @param message
     *            发送消息
     * @throws MessageSendException
     *             消息队列发送异常
     */
    void sendToQueue(Message message) throws MessageSendException;

    /**
     * 发送列表到队列中
     *
     * @param messages
     *            发送消息集
     * @throws MessageSendException
     *             消息队列发送异常
     */
    void sendToQueue(List<Message> messages) throws MessageSendException;

}