[incubator-shenyu] branch master updated: [ISSUE #2366] remove warning codes in shenyu-disruptor module (#2369)

[xiaoyu]

This is an automated email from the ASF dual-hosted git repository.

xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new 2affc22  [ISSUE #2366] remove warning codes in shenyu-disruptor module 
(#2369)
2affc22 is described below

commit 2affc223981e9761c18ea9eaa3c4a8ced4c90ab7
Author: 飞鸿雪泥 <songyuequan...@163.com>
AuthorDate: Tue Nov 16 17:08:20 2021 +0800

    [ISSUE #2366] remove warning codes in shenyu-disruptor module (#2369)
    
    * [ISSUE #2366] remove warning codes in shenyu-disruptor module
    
    * cancel ThreadFactory NonNull
    
    * remove version in disruptor dependency
---
 shenyu-disruptor/pom.xml                                            | 1 -
 .../java/org/apache/shenyu/disruptor/DisruptorProviderManage.java   | 6 +++---
 .../java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java    | 4 ++--
 .../org/apache/shenyu/disruptor/provider/DisruptorProvider.java     | 2 +-
 4 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/shenyu-disruptor/pom.xml b/shenyu-disruptor/pom.xml
index 19e5b6d..2c4fa00 100644
--- a/shenyu-disruptor/pom.xml
+++ b/shenyu-disruptor/pom.xml
@@ -29,7 +29,6 @@
         <dependency>
             <groupId>com.lmax</groupId>
             <artifactId>disruptor</artifactId>
-            <version>3.4.0</version>
         </dependency>
     </dependencies>
 </project>
\ No newline at end of file
diff --git 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/DisruptorProviderManage.java
 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/DisruptorProviderManage.java
index 95a3efd..989d4e8 100644
--- 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/DisruptorProviderManage.java
+++ 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/DisruptorProviderManage.java
@@ -50,11 +50,11 @@ public class DisruptorProviderManage<T> {
 
     private DisruptorProvider<T> provider;
 
-    private Integer consumerSize;
+    private final Integer consumerSize;
 
-    private QueueConsumerFactory<T> consumerFactory;
+    private final QueueConsumerFactory<T> consumerFactory;
     
-    private ExecutorService executor;
+    private final ExecutorService executor;
 
     /**
      * Instantiates a new Disruptor provider manage.
diff --git 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java
 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java
index 06255a0..a6603a7 100644
--- 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java
+++ 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java
@@ -29,9 +29,9 @@ import java.util.concurrent.ExecutorService;
  */
 public class QueueConsumer<T> implements WorkHandler<DataEvent<T>> {
     
-    private ExecutorService executor;
+    private final ExecutorService executor;
     
-    private QueueConsumerFactory<T> factory;
+    private final QueueConsumerFactory<T> factory;
     
     /**
      * Instantiates a new Queue consumer.
diff --git 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/provider/DisruptorProvider.java
 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/provider/DisruptorProvider.java
index ef38891..9b5948c 100644
--- 
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/provider/DisruptorProvider.java
+++ 
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/provider/DisruptorProvider.java
@@ -40,7 +40,7 @@ public class DisruptorProvider<T> {
     /**
      * The Logger.
      */
-    private Logger logger = LoggerFactory.getLogger(DisruptorProvider.class);
+    private final Logger logger = 
LoggerFactory.getLogger(DisruptorProvider.class);
     
     /**
      * Instantiates a new Disruptor provider.