模块 org.redkale

程序包 org.redkale.mq

接口 MessageProducer

所有已知实现类:

MessageAgent.MessageProducerWrapper

public interface MessageProducer

MQ消息发送器 ResourceProducer

详情见: 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)