模块 org.redkale

程序包 org.redkale.mq

接口 MessageProducer

所有已知实现类:

MessageAgent.MessageProducerWrapper

public interface MessageProducer

MQ消息发送器 ResourceProducer

 public class TestMessageService extends AbstractService {

     @ResourceProducer(mq = "mymq")
      private MessageProducer producer;

      @Override
      public void init(AnyValue config) {
           sendMessage();
      }

      public void sendMessage() {
           TestBean bean = new TestBean(12345, "this is a message");
           System.out.println("生产消息: " + bean);
           producer.sendMessage("test_bean_topic", bean);
      }
 }
 

详情见: https://redkale.org

从以下版本开始:

2.8.0

作者:

zhangjx

另请参阅:

ResourceProducer

方法概要

修饰符和类型	方法	说明
default CompletableFuture<Void>	sendMessage(String topic, Integer partition, Object value)
default CompletableFuture<Void>	sendMessage(String topic, Integer partition, Convert convert, Object value)
CompletableFuture<Void>	sendMessage(String topic, Integer partition, Convert convert, Type type, Object value)
default CompletableFuture<Void>	sendMessage(String topic, Object value)
default CompletableFuture<Void>	sendMessage(String topic, Convert convert, Object value)
default CompletableFuture<Void>	sendMessage(String topic, Convert convert, Type type, Object value)

方法详细资料

sendMessage

CompletableFuture<Void> sendMessage(String topic,
                                    Integer partition,
                                    Convert convert,
                                    Type type,
                                    Object value)

sendMessage

default CompletableFuture<Void> sendMessage(String topic,
                                            Integer partition,
                                            Convert convert,
                                            Object value)

sendMessage

default CompletableFuture<Void> sendMessage(String topic,
                                            Integer partition,
                                            Object value)

sendMessage

default CompletableFuture<Void> sendMessage(String topic,
                                            Convert convert,
                                            Type type,
                                            Object value)

sendMessage

default CompletableFuture<Void> sendMessage(String topic,
                                            Convert convert,
                                            Object value)

sendMessage

default CompletableFuture<Void> sendMessage(String topic,
                                            Object value)