io.appactive.java.api.bridge.mq.producer

接口 MqProducerService<T>

public interface MqProducerService<T>

方法概要

限定符和类型	方法和说明
void	addAttribute(T message, MessageAttributeService messageAttributeService) add attribute
MQPubChainStatusEnum	send(MessageUnitService<T> messageUnitService) judge weather a message is legal

方法详细资料

addAttribute

void addAttribute(T message,
                  MessageAttributeService messageAttributeService)

add attribute

参数:

message - the message

messageAttributeService - service that can handle messages

send

MQPubChainStatusEnum send(MessageUnitService<T> messageUnitService)

judge weather a message is legal

参数:

messageUnitService - service that can handle messages

返回:

how we handle this message