pzx6b666 commented on issue #764:
URL:
https://github.com/apache/rocketmq-clients/issues/764#issuecomment-2134525742
> 本来就是这样的，你都关闭生产者了，他肯定报错呀
第一次调用发送完消息以后执行close，再次调用不应该重新初始化吗
sendmsg(){
final ClientServiceProvider provider = ClientServiceProvider.loadService();
String topic = "yourNormalTopic";
final Producer producer = ProducerSingleton.getInstance(topic);
byte[] body = "This is a normal message for Apache
RocketMQ".getBytes(StandardCharsets.UTF_8);
String tag = "yourMessageTagA";
final Message message = provider.newMessageBuilder()
.setTopic(topic)
.setTag(tag)
.setKeys("yourMessageKey-1c151062f96e")
.setBody(body)
.build();
try {
final SendReceipt sendReceipt = producer.send(message);
log.info("Send message successfully, messageId={}",
sendReceipt.getMessageId());
} catch (Throwable t) {
log.error("Failed to send message", t);
}finally{
producer.close()
}
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
