Showing
1 changed file
with
1 additions
and
2 deletions
@@ -47,13 +47,12 @@ public abstract class AbsOrderAutoCancelDelayMsgConsumer implements YhConsumer { | @@ -47,13 +47,12 @@ public abstract class AbsOrderAutoCancelDelayMsgConsumer implements YhConsumer { | ||
47 | return; | 47 | return; |
48 | } | 48 | } |
49 | mqConsumerLog.warn("handle {} message fail, message is {} ",topic, message, serviceEx); | 49 | mqConsumerLog.warn("handle {} message fail, message is {} ",topic, message, serviceEx); |
50 | - //TODO find where is ORDER_CANCEL_FAILED_NOT_FIT_TIME used | ||
51 | if(serviceEx.getServiceError() == ServiceError.ORDER_CANCEL_FAILED_NOT_FIT_TIME) { | 50 | if(serviceEx.getServiceError() == ServiceError.ORDER_CANCEL_FAILED_NOT_FIT_TIME) { |
52 | autoCancelOrderRetry(orderCancelEvent); | 51 | autoCancelOrderRetry(orderCancelEvent); |
53 | } | 52 | } |
54 | } catch ( Exception e ) { | 53 | } catch ( Exception e ) { |
55 | - | ||
56 | mqConsumerLog.warn("handle {} message fail, message is {} ",topic, message, e); | 54 | mqConsumerLog.warn("handle {} message fail, message is {} ",topic, message, e); |
55 | + autoCancelOrderRetry(orderCancelEvent); | ||
57 | } | 56 | } |
58 | } | 57 | } |
59 | 58 |
-
Please register or login to post a comment