package com.iplatform.tcp.lb;
|
|
import org.apache.rocketmq.client.producer.SendCallback;
|
import org.apache.rocketmq.client.producer.SendResult;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
/**
|
* 消息发送回调定义。
|
* <p>暂时还不知道如何使用（在哪个地方使用）</p>
|
* @date 2023-09-26
|
*/
|
public class SendStatusCallback implements SendCallback {
|
|
protected final transient Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
@Override
|
public void onSuccess(SendResult sendResult) {
|
logger.debug("消息发送成功：{}", sendResult.getMsgId());
|
}
|
|
@Override
|
public void onException(Throwable throwable) {
|
logger.error("消息发送失败：", throwable);
|
}
|
}
|
