package com.zt.common.message.producer;

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

import java.util.List;

/**
 * 同步队列发送，内部应用
 *
 * @author wacxhs
 */
public class SynchronousQueueProducer extends AbstractMessageQueue implements MessageProducer {

    @Override
    public void sendToQueue(Message message) throws MessageSendException {
        handleMessage(message);
    }

    @Override
    public void sendToQueue(List<Message> messages) throws MessageSendException {
        if (messages != null && !messages.isEmpty()) {
            for (Message message : messages) {
                sendToQueue(message);
            }
        }
    }
}