[pulsar] branch branch-2.10 updated: [fix][branch-2.10]Fix compilation issue introduced byfix Repeated messages of shared dispatcher (#16812)

[xiangying]

This is an automated email from the ASF dual-hosted git repository.

xiangying pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 3548d674c50 [fix][branch-2.10]Fix compilation issue introduced byfix 
Repeated messages of shared dispatcher (#16812)
3548d674c50 is described below

commit 3548d674c50b418689d53103671b7104d335737f
Author: xiangying <1984997...@qq.com>
AuthorDate: Wed Jul 5 14:47:41 2023 +0800

    [fix][branch-2.10]Fix compilation issue introduced byfix Repeated messages 
of shared dispatcher (#16812)
---
 .../persistent/PersistentStickyKeyDispatcherMultipleConsumersTest.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersTest.java
index ede9baa8fff..fa9810a63c3 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersTest.java
@@ -103,7 +103,6 @@ public class 
PersistentStickyKeyDispatcherMultipleConsumersTest {
         doReturn(100).when(configMock).getDispatcherMaxReadBatchSize();
         
doReturn(true).when(configMock).isSubscriptionKeySharedUseConsistentHashing();
         
doReturn(1).when(configMock).getSubscriptionKeySharedConsistentHashingReplicaPoints();
-        
doReturn(true).when(configMock).isDispatcherDispatchMessagesInSubscriptionThread();
 
         pulsarMock = mock(PulsarService.class);
         doReturn(configMock).when(pulsarMock).getConfiguration();
@@ -117,7 +116,7 @@ public class 
PersistentStickyKeyDispatcherMultipleConsumersTest {
         EventLoopGroup eventLoopGroup = mock(EventLoopGroup.class);
         doReturn(eventLoopGroup).when(brokerMock).executor();
         doAnswer(invocation -> {
-            orderedExecutor.execute(((Runnable)invocation.getArguments()[0]));
+            ((Runnable)invocation.getArguments()[0]).run();
             return null;
         }).when(eventLoopGroup).execute(any(Runnable.class));