Commit b63be05ffad15be685bf5c5f26c82d8184bb3781

Authored by ShvaykaD
Committed by Andrew Shvayka
1 parent 560b950a

revert the enqueue(root rule chain) method changes

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