From 370ff7d25dd7c6eb205288f5e585a25222f81757 Mon Sep 17 00:00:00 2001 From: luozukai Date: Thu, 18 Apr 2019 09:12:56 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=B6=88=E6=81=AF=E7=BB=84=E4=BB=B6][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9][=E4=BF=AE=E6=94=B9status=5Fmessage=E5=AD=97?= =?UTF-8?q?=E6=AE=B5=E7=B1=BB=E5=9E=8B]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resources/db/migration/V201904180909__ADD_FLOW.sql | 3 +++ .../src/main/java/com/iformall/mq/MqBaseConsumer.java | 9 +++------ 2 files changed, 6 insertions(+), 6 deletions(-) create mode 100644 mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql diff --git a/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql b/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql new file mode 100644 index 000000000..daee928c2 --- /dev/null +++ b/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql @@ -0,0 +1,3 @@ + + +alter table `wx_msg_record` modify column status_message text; \ No newline at end of file diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index eca04fa9c..b364f852a 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -30,8 +30,6 @@ public class MqBaseConsumer { private SendMpMsgServiceImpl sendMpMsgService; @Autowired private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; -// @Autowired -// private MqBaseProducer mqBaseProducer; public void doMessage(String message) { log.info("received message: {}", message); @@ -61,14 +59,13 @@ public class MqBaseConsumer { } baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); wxMsgRecordMapper.update(baseMsg); - }catch (Exception e){ + }catch (Throwable e){ try { - log.error("consum received error:{} ", e.getMessage()); log.error("consum received error: ", e); - //baseMsg.setStatusMessage(e.getMessage()); + baseMsg.setStatusMessage(e.getMessage()); baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); wxMsgRecordMapper.update(baseMsg); - }catch (Exception e1){ + }catch (Throwable e1){ log.error("更新db状态error: ", e1); }