Skip to content

Commit d20cdd8

Browse files
author
王松松
committed
Fixed : code style
1 parent 7b256eb commit d20cdd8

File tree

3 files changed

+30
-33
lines changed

3 files changed

+30
-33
lines changed

‎client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,19 @@
1616
*/
1717
package org.apache.rocketmq.client.impl.consumer;
1818

19+
import java.util.ArrayList;
20+
import java.util.Collections;
21+
import java.util.HashMap;
22+
import java.util.Iterator;
23+
import java.util.List;
24+
import java.util.Map;
25+
import java.util.concurrent.BlockingQueue;
26+
import java.util.concurrent.Executors;
27+
import java.util.concurrent.LinkedBlockingQueue;
28+
import java.util.concurrent.RejectedExecutionException;
29+
import java.util.concurrent.ScheduledExecutorService;
30+
import java.util.concurrent.ThreadPoolExecutor;
31+
import java.util.concurrent.TimeUnit;
1932
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
2033
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
2134
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
@@ -35,20 +48,6 @@
3548
import org.apache.rocketmq.remoting.common.RemotingHelper;
3649
import org.slf4j.Logger;
3750

38-
import java.util.ArrayList;
39-
import java.util.Collections;
40-
import java.util.HashMap;
41-
import java.util.Iterator;
42-
import java.util.List;
43-
import java.util.Map;
44-
import java.util.concurrent.BlockingQueue;
45-
import java.util.concurrent.Executors;
46-
import java.util.concurrent.LinkedBlockingQueue;
47-
import java.util.concurrent.RejectedExecutionException;
48-
import java.util.concurrent.ScheduledExecutorService;
49-
import java.util.concurrent.ThreadPoolExecutor;
50-
import java.util.concurrent.TimeUnit;
51-
5251
public class ConsumeMessageConcurrentlyService implements ConsumeMessageService {
5352
private static final Logger log = ClientLogger.getLog();
5453
private final DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;

‎client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,16 @@
1616
*/
1717
package org.apache.rocketmq.client.impl.consumer;
1818

19+
import java.util.ArrayList;
20+
import java.util.Collections;
21+
import java.util.HashMap;
22+
import java.util.List;
23+
import java.util.concurrent.BlockingQueue;
24+
import java.util.concurrent.Executors;
25+
import java.util.concurrent.LinkedBlockingQueue;
26+
import java.util.concurrent.ScheduledExecutorService;
27+
import java.util.concurrent.ThreadPoolExecutor;
28+
import java.util.concurrent.TimeUnit;
1929
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
2030
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
2131
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
@@ -38,17 +48,6 @@
3848
import org.apache.rocketmq.remoting.common.RemotingHelper;
3949
import org.slf4j.Logger;
4050

41-
import java.util.ArrayList;
42-
import java.util.Collections;
43-
import java.util.HashMap;
44-
import java.util.List;
45-
import java.util.concurrent.BlockingQueue;
46-
import java.util.concurrent.Executors;
47-
import java.util.concurrent.LinkedBlockingQueue;
48-
import java.util.concurrent.ScheduledExecutorService;
49-
import java.util.concurrent.ThreadPoolExecutor;
50-
import java.util.concurrent.TimeUnit;
51-
5251
public class ConsumeMessageOrderlyService implements ConsumeMessageService {
5352
private static final Logger log = ClientLogger.getLog();
5453
private final static long MAX_TIME_CONSUME_CONTINUOUSLY =

‎store/src/main/java/org/apache/rocketmq/store/CommitLog.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,13 @@
1616
*/
1717
package org.apache.rocketmq.store;
1818

19+
import java.nio.ByteBuffer;
20+
import java.util.ArrayList;
21+
import java.util.HashMap;
22+
import java.util.List;
23+
import java.util.Map;
24+
import java.util.concurrent.CountDownLatch;
25+
import java.util.concurrent.TimeUnit;
1926
import org.apache.rocketmq.common.ServiceThread;
2027
import org.apache.rocketmq.common.UtilAll;
2128
import org.apache.rocketmq.common.constant.LoggerName;
@@ -32,14 +39,6 @@
3239
import org.slf4j.Logger;
3340
import org.slf4j.LoggerFactory;
3441

35-
import java.nio.ByteBuffer;
36-
import java.util.ArrayList;
37-
import java.util.HashMap;
38-
import java.util.List;
39-
import java.util.Map;
40-
import java.util.concurrent.CountDownLatch;
41-
import java.util.concurrent.TimeUnit;
42-
4342
/**
4443
* Store all metadata downtime for recovery, data protection reliability
4544
*/

0 commit comments

Comments
 (0)