You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/09/09 08:26:13 UTC
[pulsar] branch branch-2.8 updated: Fix cherry-pick issue
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.8 by this push:
new 32a7ea1 Fix cherry-pick issue
32a7ea1 is described below
commit 32a7ea1d6a3f961b71c1a234217223aefa3f8da6
Author: penghui <pe...@apache.org>
AuthorDate: Thu Sep 9 16:24:57 2021 +0800
Fix cherry-pick issue
---
.../client/api/NonDurableSubscriptionTest.java | 28 ----------------------
1 file changed, 28 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java
index bef6274..7f1f25b 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonDurableSubscriptionTest.java
@@ -65,34 +65,6 @@ public class NonDurableSubscriptionTest extends ProducerConsumerBase {
super.internalCleanup();
}
- @Override
- protected PulsarService newPulsarService(ServiceConfiguration conf) throws Exception {
- return new PulsarService(conf) {
-
- @Override
- protected BrokerService newBrokerService(PulsarService pulsar) throws Exception {
- BrokerService broker = new BrokerService(this, ioEventLoopGroup);
- broker.setPulsarChannelInitializerFactory(
- (_pulsar, tls) -> {
- return new PulsarChannelInitializer(_pulsar, tls) {
- @Override
- protected ServerCnx newServerCnx(PulsarService pulsar) throws Exception {
- return new ServerCnx(pulsar) {
-
- @Override
- protected void handleFlow(CommandFlow flow) {
- super.handleFlow(flow);
- numFlow.incrementAndGet();
- }
- };
- }
- };
- });
- return broker;
- }
- };
- }
-
@Test
public void testNonDurableSubscription() throws Exception {
String topicName = "persistent://my-property/my-ns/nonDurable-topic1";