yaoll hace 4 años
padre
commit
3552050ee4

+ 1 - 5
dmp-admin/src/main/java/com/persagy/dmp/admin/jms/executor/TransObjectExecutor.java

@@ -58,17 +58,13 @@ public class TransObjectExecutor implements MessageExecutor {
 			// 处理失效数据
 			transObjectService.transInvalidObject(ctx);
 
-
 		} catch (Exception e) {
-			e.printStackTrace();
+			transObjectService.error(ctx, e.getMessage());
 		} finally {
 			transObjectService.over(ctx);
 		}
-
-
 	}
 
-
 	private TransObjectContext prepareContext(DmpMessage message) {
 		String groupCode = message.getGroupCode();
 		String projectId = message.getProjectId();

+ 4 - 0
dmp-admin/src/main/java/com/persagy/dmp/admin/service/DmpTransObjectService.java

@@ -285,6 +285,10 @@ public class DmpTransObjectService {
         transUtils.transInvalidObject(ctx);
     }
 
+    public void error(TransObjectContext context, String message) {
+        transUtils.writeInfo(context, "error", message);
+    }
+
     public void over(TransObjectContext context) {
         transUtils.writeInfo(context, "over", null);
         String key = KEY_TRANS + context.getProjectId();