xin.alum.aim.rocketmq

类 RocketMqProducer

java.lang.Object

xin.alum.aim.rocketmq.RocketMqProducer

public class RocketMqProducer
extends Object

构造器概要

构造器

构造器和说明
RocketMqProducer(RocketMQConfig config, org.apache.rocketmq.client.apis.ClientServiceProvider provider, org.apache.rocketmq.client.apis.producer.Producer producer)

方法概要

限定符和类型	方法和说明
void	send(String tag, byte[] body) 同步消息
void	sendAsync(String tag, byte[] body) 发布消息
void	sendAsync(String tag, String message) 发布消息

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RocketMqProducer

public RocketMqProducer(RocketMQConfig config,
                        org.apache.rocketmq.client.apis.ClientServiceProvider provider,
                        org.apache.rocketmq.client.apis.producer.Producer producer)

方法详细资料

sendAsync

public void sendAsync(String tag,
                      String message)

发布消息

sendAsync

public void sendAsync(String tag,
                      byte[] body)

发布消息

send

public void send(String tag,
                 byte[] body)

同步消息