|
|
@@ -31,6 +31,7 @@ public class RocketConsumerSimulationTaskListener implements MessageListener {
|
|
|
log.info("===== recon-simulation-开始消费 =====");
|
|
|
String value = new String(message.getBody(), StandardCharsets.UTF_8);
|
|
|
// 调用业务层操作
|
|
|
+ value = value.replaceAll("\"","");
|
|
|
this.executeFunc(value);
|
|
|
return Action.CommitMessage;
|
|
|
} catch (Exception e) {
|