Skip to content

Commit 6de0430

Browse files
fix[client]: update pulsar version and use MessageListenerExecutor from pulsar-client release lib (apache#15)
### Motivation Replace the mock `MessageListenerExecutor` with the official package
1 parent 892df92 commit 6de0430

File tree

4 files changed

+3
-41
lines changed

4 files changed

+3
-41
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
<maven.compiler.release>17</maven.compiler.release>
3636
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
3737
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
38-
<pulsar.version>3.3.1</pulsar.version>
38+
<pulsar.version>4.0.5</pulsar.version>
3939
<maven-checkstyle-plugin.version>3.4.0</maven-checkstyle-plugin.version>
4040
<puppycrawl.checkstyle.version>8.45.1</puppycrawl.checkstyle.version>
4141
<spotless-maven-plugin.version>2.43.0</spotless-maven-plugin.version>

pulsar-client-common-contrib/src/main/java/org/apache/pulsar/client/api/MessageListenerExecutor.java

Lines changed: 0 additions & 38 deletions
This file was deleted.

pulsar-client-common-contrib/src/main/java/org/apache/pulsar/client/api/impl/KeySharedMessageListenerExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public class KeySharedMessageListenerExecutor implements MessageListenerExecutor
2424

2525
public KeySharedMessageListenerExecutor(int numThreads, String subscriptionName) {
2626
this.executorProvider =
27-
new ExecutorProvider(numThreads, subscriptionName + "listener-executor-");
27+
new ExecutorProvider(numThreads, subscriptionName + "-listener-executor");
2828
}
2929

3030
@Override

pulsar-client-common-contrib/src/main/java/org/apache/pulsar/client/api/impl/PartitionOrderMessageListenerExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public class PartitionOrderMessageListenerExecutor implements MessageListenerExe
2323

2424
public PartitionOrderMessageListenerExecutor(int numThreads, String subscriptionName) {
2525
this.executorProvider =
26-
new ExecutorProvider(numThreads, subscriptionName + "listener-executor-");
26+
new ExecutorProvider(numThreads, subscriptionName + "-listener-executor");
2727
}
2828

2929
@Override

0 commit comments

Comments
 (0)