init

jinlin

2023-11-03 35435e8b1995e6775c82b86652381e07e3faff54

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
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);
            }
        }
    }
}