Pass the check style

apache · Feb 27, 2023 · 9182618 · 9182618
1 parent 091d189
commit 9182618
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...t/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/...t/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -159,7 +159,8 @@ private enum SubscriptionType {
     private final ArrayList<ConsumeMessageHook> consumeMessageHookList = new ArrayList<>();
 
     // only for test purpose, will be modified by reflection in unit test.
-    @SuppressWarnings("FieldMayBeFinal") private static boolean doNotUpdateTopicSubscribeInfoWhenSubscriptionChanged = false;
+    @SuppressWarnings("FieldMayBeFinal")
+    private static boolean doNotUpdateTopicSubscribeInfoWhenSubscriptionChanged = false;
 
     public DefaultLitePullConsumerImpl(final DefaultLitePullConsumer defaultLitePullConsumer, final RPCHook rpcHook) {
         this.defaultLitePullConsumer = defaultLitePullConsumer;
@@ -485,12 +486,14 @@ private void updateTopicSubscribeInfoWhenSubscriptionChanged() {
 
     /**
      * subscribe data by customizing messageQueueListener
+     *
      * @param topic
      * @param subExpression
      * @param messageQueueListener
      * @throws MQClientException
      */
-    public synchronized void subscribe(String topic, String subExpression, MessageQueueListener messageQueueListener) throws MQClientException {
+    public synchronized void subscribe(String topic, String subExpression,
+        MessageQueueListener messageQueueListener) throws MQClientException {
         try {
             if (StringUtils.isEmpty(topic)) {
                 throw new IllegalArgumentException("Topic can not be null or empty.");
@@ -517,7 +520,6 @@ public void messageQueueChanged(String topic, Set<MessageQueue> mqAll, Set<Messa
         }
     }
 
-
     public synchronized void subscribe(String topic, String subExpression) throws MQClientException {
         try {
             if (topic == null || "".equals(topic)) {
@@ -734,6 +736,7 @@ public synchronized void commitAll() {
 
     /**
      * Specify offset commit
+     *
      * @param messageQueues
      * @param persist
      */
@@ -762,6 +765,7 @@ public synchronized void commit(final Map<MessageQueue, Long> messageQueues, boo
 
     /**
      * Get the queue assigned in subscribe mode
+     *
      * @return
      */
     public synchronized Set<MessageQueue> assignment() {
@@ -1177,7 +1181,7 @@ public ConsumerRunningInfo consumerRunningInfo() {
 
         info.getSubscriptionSet().addAll(this.subscriptions());
 
-        for (MessageQueue mq :this.assignedMessageQueue.getAssignedMessageQueues()){
+        for (MessageQueue mq : this.assignedMessageQueue.getAssignedMessageQueues()) {
             ProcessQueue pq = this.assignedMessageQueue.getProcessQueue(mq);
             ProcessQueueInfo pqInfo = new ProcessQueueInfo();
             pqInfo.setCommitOffset(this.offsetStore.readOffset(mq, ReadOffsetType.MEMORY_FIRST_THEN_STORE));
@@ -1247,7 +1251,7 @@ public AssignedMessageQueue getAssignedMessageQueue() {
     }
 
     public synchronized void registerTopicMessageQueueChangeListener(String topic,
-                                                                     TopicMessageQueueChangeListener listener) throws MQClientException {
+        TopicMessageQueueChangeListener listener) throws MQClientException {
         if (topic == null || listener == null) {
             throw new MQClientException("Topic or listener is null", null);
         }