Commit d5bf25e2f346892bdbb4beffbcfb37ffc9c7425c

Authored by ShvaykaD
Committed by Andrew Shvayka
1 parent a045be77

revert the enqueue(root rule chain) method changes

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