format

common/script/pom.xml

@@ -27,10 +27,6 @@
             <groupId>com.thing.common</groupId>
             <artifactId>util</artifactId>
         </dependency>
-        <dependency>
-            <groupId>com.thing.common</groupId>
-            <artifactId>core</artifactId>
-        </dependency>
         <dependency>
             <groupId>org.javadelight</groupId>
             <artifactId>delight-nashorn-sandbox</artifactId>
@@ -55,6 +51,10 @@
             <groupId>com.thing.common</groupId>
             <artifactId>tskv</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
 
     </dependencies>
 </project>

modules/dequeue/src/main/java/com/thing/queue/DefaultCoreConsumerService.java

@@ -285,6 +285,7 @@ public class DefaultCoreConsumerService extends AbstractConsumerService<Transpor
             ScriptCache scriptCache = Objects.isNull(calculationId) ? null : scriptCacheService.get(String.valueOf(calculationId));
             if (Objects.isNull(scriptCache)) {
                 entity.setOutputMsg(inputMsg);
+                return;
             }
             ScriptLanguage scriptLanguage =  ScriptLanguage.get(scriptCache.getScriptType());
             ScriptEngine scriptEngine = scriptCreateService.createScriptEngine(scriptCache.getScriptEId(), scriptLanguage, scriptCache.getScriptBody(), scriptCache.getDebug());

modules/thing/src/main/java/com/thing/thing/cache/service/ThingCache.java

@@ -158,7 +158,7 @@ public final class ThingCache {
 
     public void printStats() {
         thingMap.forEach((topic, queue) -> {
-            log.info("---dataMap-内存主题:{}----->数据量:{}------{}", topic, queue.size(), queue);
+            log.info("---dataMap-内存主题:{}----->数据量:{}", topic, queue.size());
         });
     }