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);
    }
}