fix duplicates

@@ -119,7 +119,7 @@ class DefaultTbContext implements TbContext {
 
 
     @Override
     @Override
     public void enqueue(TbMsg tbMsg, Runnable onSuccess, Consumer<Throwable> onFailure) {
     public void enqueue(TbMsg tbMsg, Runnable onSuccess, Consumer<Throwable> onFailure) {
-        TopicPartitionInfo tpi = mainCtx.resolve(ServiceType.TB_RULE_ENGINE, getTenantId(), tbMsg.getOriginator());
+        TopicPartitionInfo tpi = resolvePartition(tbMsg);
         enqueue(tpi, tbMsg, onFailure, onSuccess);
         enqueue(tpi, tbMsg, onFailure, onSuccess);
     }
     }