cn.springlet.rocketmq.log

类 LogUtil

java.lang.Object

cn.springlet.rocketmq.log.LogUtil

所有已实现的接口:

Serializable

public class LogUtil
extends Object
implements Serializable

rocketmq 日志处理

作者:

springlet

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
LogUtil()

方法概要

限定符和类型	方法和说明
static void	consumerError(com.aliyun.openservices.ons.api.Message msg, Exception e) 消息消费失败
static void	consumerSuccess(com.aliyun.openservices.ons.api.Message msg, MsgKeyEnum msgKeyEnum) 消息消费成功
static void	receive(com.aliyun.openservices.ons.api.Message msg, MsgKeyEnum msgKeyEnum, Object bodyObj) 接收消息
static void	sendError(com.aliyun.openservices.ons.api.Message msg, Exception e) 发送消息失败
static void	sendSuccess(com.aliyun.openservices.ons.api.Message msg, String messageId) 发送消息成功

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

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

构造器详细资料

LogUtil

public LogUtil()

方法详细资料

sendSuccess

public static void sendSuccess(com.aliyun.openservices.ons.api.Message msg,
                               String messageId)

发送消息成功

参数:

msg -

messageId -

sendError

public static void sendError(com.aliyun.openservices.ons.api.Message msg,
                             Exception e)

发送消息失败

参数:

msg -

e -

receive

public static void receive(com.aliyun.openservices.ons.api.Message msg,
                           MsgKeyEnum msgKeyEnum,
                           Object bodyObj)

接收消息

参数:

msg -

msgKeyEnum -

consumerSuccess

public static void consumerSuccess(com.aliyun.openservices.ons.api.Message msg,
                                   MsgKeyEnum msgKeyEnum)

消息消费成功

参数:

msg -

msgKeyEnum -

consumerError

public static void consumerError(com.aliyun.openservices.ons.api.Message msg,
                                 Exception e)

消息消费失败

参数:

msg -

e -