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);
|
}
|
}
|
}
|
}
|
