check style

aloyszhang · Feb 22, 2022 · c4c1a0d · c4c1a0d
1 parent 8119438
commit c4c1a0d
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 6 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -1014,12 +1014,14 @@ protected void handleSubscribe(final CommandSubscribe subscribe) {
                                                         subType, priorityLevel, consumerName, isDurable,
                                                         startMessageId, metadata,
                                                         readCompacted, initialPosition, startMessageRollbackDurationSec,
-                                                        isReplicated, keySharedMeta, autoShrink));
+                                                        isReplicated, keySharedMeta,
+                                                        autoShrink));
                                     } else {
                                         return topic.subscribe(ServerCnx.this, subscriptionName, consumerId,
                                             subType, priorityLevel, consumerName, isDurable,
                                             startMessageId, metadata, readCompacted, initialPosition,
-                                            startMessageRollbackDurationSec, isReplicated, keySharedMeta, autoShrink);
+                                            startMessageRollbackDurationSec, isReplicated,
+                                                keySharedMeta, autoShrink);
                                     }
                                 })
                                 .thenAccept(consumer -> {

diff --git a/...oker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java b/...oker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -289,8 +289,10 @@ public CompletableFuture<Consumer> subscribe(final TransportCnx cnx, String subs
 
         NonPersistentSubscription subscription = subscriptions.computeIfAbsent(subscriptionName,
                 name -> new NonPersistentSubscription(this, subscriptionName, isDurable));
-        Consumer consumer = new Consumer(subscription, subType, topic, consumerId, priorityLevel, consumerName, 0,
-                cnx, cnx.getAuthRole(), metadata, readCompacted, initialPosition, keySharedMeta, MessageId.latest, autoShrink);
+        Consumer consumer = new Consumer(subscription, subType, topic, consumerId,
+                priorityLevel, consumerName, 0,
+                cnx, cnx.getAuthRole(), metadata, readCompacted, initialPosition,
+                keySharedMeta, MessageId.latest, autoShrink);
         addConsumerToSubscription(subscription, consumer).thenRun(() -> {
             if (!cnx.isActive()) {
                 try {

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -763,9 +763,11 @@ public CompletableFuture<Consumer> subscribe(final TransportCnx cnx, String subs
                 : 0;
 
         subscriptionFuture.thenAccept(subscription -> {
-            Consumer consumer = new Consumer(subscription, subType, topic, consumerId, priorityLevel, consumerName,
+            Consumer consumer = new Consumer(subscription, subType, topic,
+                    consumerId, priorityLevel, consumerName,
                     maxUnackedMessages, cnx, cnx.getAuthRole(), metadata,
-                    readCompacted, initialPosition, keySharedMeta, startMessageId, autoShrink);
+                    readCompacted, initialPosition, keySharedMeta,
+                    startMessageId, autoShrink);
             addConsumerToSubscription(subscription, consumer).thenAccept(v -> {
                 checkBackloggedCursors();
                 if (!cnx.isActive()) {