|
@@ -57,6 +57,7 @@ public class JobTaskConsumer {
|
|
|
channel.basicAck(tag, false);
|
|
|
} catch (Exception e) {
|
|
|
log.error("消费数据失败",e);
|
|
|
+ e.printStackTrace();
|
|
|
channel.basicNack(tag, false, true);
|
|
|
jobTaskService.updateTaskState(taskId,TaskState.FAILED,e.getMessage());
|
|
|
}
|