记得上下班打卡 | git大法好,push需谨慎

Commit 9adef268 authored by jiangxiulong's avatar jiangxiulong

log

parent 1a03cbf4
...@@ -32,18 +32,14 @@ public class ConsumerGoblinBizIntegralReceiver extends AbstractBizRedisReceiver ...@@ -32,18 +32,14 @@ public class ConsumerGoblinBizIntegralReceiver extends AbstractBizRedisReceiver
@Override @Override
protected boolean consumerMessageHandler(String msg) { protected boolean consumerMessageHandler(String msg) {
long s = System.currentTimeMillis();
boolean aBoolean = false; boolean aBoolean = false;
try { try {
GoblinQueueBizIntegralDto fromJsonObj = JsonUtils.fromJson(msg, GoblinQueueBizIntegralDto.class); GoblinQueueBizIntegralDto fromJsonObj = JsonUtils.fromJson(msg, GoblinQueueBizIntegralDto.class);
log.info("转换s:{}", System.currentTimeMillis() - s);
if (fromJsonObj == null) { if (fromJsonObj == null) {
log.warn("CONSUMER MSG NULL_DTO ==> [{}]:{}", this.getRedisStreamKey(), msg); log.warn("CONSUMER MSG NULL_DTO ==> [{}]:{}", this.getRedisStreamKey(), msg);
aBoolean = true; aBoolean = true;
} else { } else {
log.info("开始请求s:{}", System.currentTimeMillis() - s);
aBoolean = this.bizIntegralProcessing(fromJsonObj); aBoolean = this.bizIntegralProcessing(fromJsonObj);
log.info("请求结束s:{}", System.currentTimeMillis() - s);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("CONSUMER MSG EX_HANDLE ==> [{}]:{}", this.getRedisStreamKey(), msg, e); log.error("CONSUMER MSG EX_HANDLE ==> [{}]:{}", this.getRedisStreamKey(), msg, e);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment