fix: codereview

yanrongzhen · yanrongzhen · commit 60088b93526f · 2023-11-14T17:19:50.000+08:00
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/RetryContext.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/RetryContext.java
@@ -70,6 +70,11 @@ public final void run() throws Exception {
             doRun();
             return;
         }
+        if (!eventMeshRetryPluginType.equals(commonConfiguration.getEventMeshStoragePluginType())) {
+            log.warn("Because eventmesh retry plugin type mismatched with storage plugin type, retry in memory.");
+            doRun();
+            return;
+        }
         Optional<RetryStrategy> retryStrategy = Optional.ofNullable(
             EventMeshExtensionFactory.getExtension(RetryStrategy.class,
                 commonConfiguration.getEventMeshRetryPluginType()));
