| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | | LogHelper.mqInfo("consumer-SystemCouponMessageListener", message.getTopic(), message.getTag(),
|
|---|
| | | new String(message.getBody()));
|
|---|
| | | LogHelper.mqInfo("consumer-SystemCouponMessageListener", message.getMsgID(), message.getTopic(),
|
|---|
| | | message.getTag(), new String(message.getBody()));
|
|---|
| | | String tag = message.getTag();
|
|---|
| | | BaseMQMsgBody baseBody = new Gson().fromJson(new String(message.getBody()), BaseMQMsgBody.class);
|
|---|
| | | if (baseBody.isTest() != Constant.IS_TEST)
|
|---|
