[incubator-tubemq] branch master updated: [TUBEMQ-121] Fix compilation alarm (#81)

[lamberliu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b1d6965  [TUBEMQ-121] Fix compilation alarm (#81)
b1d6965 is described below

commit b1d6965b81ef557767546ecb26ffcfc5db02aeb9
Author: gosonzhang <4675...@qq.com>
AuthorDate: Fri May 15 07:32:15 2020 +0000

    [TUBEMQ-121] Fix compilation alarm (#81)
    
    Co-authored-by: gosonzhang <gosonzh...@tencent.com>
---
 .../main/java/org/apache/tubemq/corebase/utils/ConcurrentHashSet.java | 4 ++--
 .../java/org/apache/tubemq/corerpc/netty/NettyProtocolDecoder.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/ConcurrentHashSet.java
 
b/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/ConcurrentHashSet.java
index 1b938dd..9860d09 100644
--- 
a/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/ConcurrentHashSet.java
+++ 
b/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/ConcurrentHashSet.java
@@ -30,11 +30,11 @@ public class ConcurrentHashSet<E> extends MapBackedSet<E> {
     private static final long serialVersionUID = 8518578988740277828L;
 
     public ConcurrentHashSet() {
-        super(new ConcurrentHashMap<>());
+        super(new ConcurrentHashMap<E, Boolean>());
     }
 
     public ConcurrentHashSet(Collection<E> c) {
-        super(new ConcurrentHashMap<>(), c);
+        super(new ConcurrentHashMap<E, Boolean>(), c);
     }
 
     @Override
diff --git 
a/tubemq-core/src/main/java/org/apache/tubemq/corerpc/netty/NettyProtocolDecoder.java
 
b/tubemq-core/src/main/java/org/apache/tubemq/corerpc/netty/NettyProtocolDecoder.java
index 46353e7..63c4d8c 100644
--- 
a/tubemq-core/src/main/java/org/apache/tubemq/corerpc/netty/NettyProtocolDecoder.java
+++ 
b/tubemq-core/src/main/java/org/apache/tubemq/corerpc/netty/NettyProtocolDecoder.java
@@ -61,7 +61,7 @@ public class NettyProtocolDecoder extends FrameDecoder {
             filterIllegalPackageSize(true, tmpListSize,
                     RpcConstants.MAX_FRAME_MAX_LIST_SIZE, channel);
             this.listSize = tmpListSize;
-            this.dataPack = new RpcDataPack(serialNo, new 
ArrayList<>(this.listSize));
+            this.dataPack = new RpcDataPack(serialNo, new 
ArrayList<ByteBuffer>(this.listSize));
             this.packHeaderRead = true;
         }
         // get PackBody