release 0.8.0

release 0.8.0

Author: slievrly

README.md

@@ -8,10 +8,10 @@
 [![maven](https://img.shields.io/maven-central/v/io.seata/seata-parent.svg)](https://search.maven.org/search?q=io.seata)
 [![](https://img.shields.io/twitter/follow/seataio.svg?label=Follow&style=social&logoWidth=0)](https://twitter.com/intent/follow?screen_name=seataio)
 
+
 ## What is Seata?
 
 A **distributed transaction solution** with high performance and ease of use for **microservices** architecture.
-
 ### Distributed Transaction Problem in Microservices
 
 Let's imagine a traditional monolithic application. Its business is built up with 3 modules. They use a single local data source.
@@ -75,13 +75,13 @@ For more details about principle and design, please go to [Seata wiki page](http
 
 ##### Seata Community
 
-- **Seata** :Simple Extensible Autonomous Transaction Architecture. Ant Financial joins Fescar, which make it to be a more neutral and open community for distributed transaction，and Fescar be rename to Seata.
+- **Seata** :Simple Extensible Autonomous Transaction Architecture. Ant Financial joins Fescar, which make it to be a more neutral and open community for distributed transaction，and Fescar be renamed to Seata.
 
 
 
 ## Maven dependency
 ```xml
-<seata.version>0.7.1</seata.version>
+<seata.version>0.8.0</seata.version>
 
 <dependency>
     <groupId>io.seata</groupId>

all/pom.xml

@@ -21,7 +21,7 @@
 
     <groupId>io.seata</groupId>
     <artifactId>seata-all</artifactId>
-    <version>0.7.1</version>
+    <version>0.8.0</version>
 
     <name>Seata All-in-one ${project.version}</name>
     <url>http://seata.io</url>

bom/pom.xml

@@ -20,7 +20,7 @@
 
     <groupId>io.seata</groupId>
     <artifactId>seata-bom</artifactId>
-    <version>0.7.1</version>
+    <version>0.8.0</version>
 
     <modelVersion>4.0.0</modelVersion>
     <packaging>pom</packaging>
@@ -65,7 +65,7 @@
 
     <properties>
         <spring.version>4.3.23.RELEASE</spring.version>
-        <netty4.version>4.1.24.Final</netty4.version>
+        <netty4.version>4.1.30.Final</netty4.version>
         <dubbo.version>2.7.0</dubbo.version>
         <dubbo.alibaba.version>2.6.5</dubbo.alibaba.version>
         <sofa.rpc.version>5.5.3</sofa.rpc.version>
@@ -234,6 +234,12 @@
                 <groupId>org.apache.zookeeper</groupId>
                 <artifactId>zookeeper</artifactId>
                 <version>${apache-zookeeper.version}</version>
+                <exclusions>
+                    <exclusion>
+                            <artifactId>io.netty</artifactId>
+                            <groupId>netty</groupId>
+                    </exclusion>
+                </exclusions>
             </dependency>
             <dependency>
                 <groupId>org.apache.curator</groupId>
@@ -307,6 +313,24 @@
                 <groupId>io.etcd</groupId>
                 <artifactId>jetcd-core</artifactId>
                 <version>${etcd-client-v3.version}</version>
+                <exclusions>
+                    <exclusion>
+                        <groupId>io.netty</groupId>
+                        <artifactId>netty-codec-http</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>io.netty</groupId>
+                        <artifactId>netty-codec-http2</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>io.netty</groupId>
+                        <artifactId>netty-handler-proxy</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>io.netty</groupId>
+                        <artifactId>netty-handler</artifactId>
+                    </exclusion>
+                </exclusions>
             </dependency>
             <dependency>
                 <groupId>com.google.guava</groupId>

codec/seata-codec-protobuf/src/main/java/io/seata/codec/protobuf/convertor/BranchRegisterRequestConvertor.java

@@ -15,12 +15,12 @@
  */
 package io.seata.codec.protobuf.convertor;
 
-import io.seata.core.model.BranchType;
 import io.seata.codec.protobuf.generated.AbstractMessageProto;
 import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
 import io.seata.codec.protobuf.generated.BranchRegisterRequestProto;
 import io.seata.codec.protobuf.generated.BranchTypeProto;
 import io.seata.codec.protobuf.generated.MessageTypeProto;
+import io.seata.core.model.BranchType;
 import io.seata.core.protocol.transaction.BranchRegisterRequest;
 
 /**
@@ -40,11 +40,12 @@ public BranchRegisterRequestProto convert2Proto(BranchRegisterRequest branchRegi
 
         final String applicationData = branchRegisterRequest.getApplicationData();
         final String resourceId = branchRegisterRequest.getResourceId();
+        final String lockKey = branchRegisterRequest.getLockKey();
         BranchRegisterRequestProto result = BranchRegisterRequestProto.newBuilder()
             .setAbstractTransactionRequest(abstractTransactionRequestProto)
-            .setApplicationData(applicationData==null?"":applicationData)
+            .setApplicationData(applicationData == null ? "" : applicationData)
             .setBranchType(BranchTypeProto.valueOf(branchRegisterRequest.getBranchType().name()))
-            .setLockKey(branchRegisterRequest.getLockKey())
+            .setLockKey(lockKey == null ? "" : lockKey)
             .setResourceId(resourceId == null ? "" : resourceId)
             .setXid(branchRegisterRequest.getXid())
             .build();

codec/seata-codec-protobuf/src/main/java/io/seata/codec/protobuf/convertor/GlobalLockQueryRequestConvertor.java

@@ -15,13 +15,13 @@
  */
 package io.seata.codec.protobuf.convertor;
 
-import io.seata.core.model.BranchType;
 import io.seata.codec.protobuf.generated.AbstractMessageProto;
 import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
 import io.seata.codec.protobuf.generated.BranchRegisterRequestProto;
 import io.seata.codec.protobuf.generated.BranchTypeProto;
 import io.seata.codec.protobuf.generated.GlobalLockQueryRequestProto;
 import io.seata.codec.protobuf.generated.MessageTypeProto;
+import io.seata.core.model.BranchType;
 import io.seata.core.protocol.transaction.GlobalLockQueryRequest;
 
 /**
@@ -41,11 +41,12 @@ public GlobalLockQueryRequestProto convert2Proto(GlobalLockQueryRequest globalLo
                 abstractMessage).build();
 
         final String applicationData = globalLockQueryRequest.getApplicationData();
+        final String lockKey = globalLockQueryRequest.getLockKey();
         BranchRegisterRequestProto branchRegisterRequestProto = BranchRegisterRequestProto.newBuilder()
             .setAbstractTransactionRequest(abstractTransactionRequestProto)
-            .setApplicationData(applicationData==null?"":applicationData)
+            .setApplicationData(applicationData == null ? "" : applicationData)
             .setBranchType(BranchTypeProto.valueOf(globalLockQueryRequest.getBranchType().name()))
-            .setLockKey(globalLockQueryRequest.getLockKey())
+            .setLockKey(lockKey == null ? "" : lockKey)
             .setResourceId(globalLockQueryRequest.getResourceId())
             .setXid(globalLockQueryRequest.getXid())
             .build();

codec/seata-codec-protobuf/src/main/java/io/seata/codec/protobuf/convertor/UndoLogDeleteRequestConvertor.java

@@ -0,0 +1,61 @@
+/*
+ *  Copyright 1999-2019 Seata.io Group.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package io.seata.codec.protobuf.convertor;
+
+import io.seata.codec.protobuf.generated.AbstractMessageProto;
+import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
+import io.seata.codec.protobuf.generated.BranchTypeProto;
+import io.seata.codec.protobuf.generated.MessageTypeProto;
+import io.seata.codec.protobuf.generated.UndoLogDeleteRequestProto;
+import io.seata.core.model.BranchType;
+import io.seata.core.protocol.transaction.UndoLogDeleteRequest;
+
+/**
+ * @author yuanguoyao
+ */
+public class UndoLogDeleteRequestConvertor implements PbConvertor<UndoLogDeleteRequest, UndoLogDeleteRequestProto> {
+    @Override
+    public UndoLogDeleteRequestProto convert2Proto(UndoLogDeleteRequest undoLogDeleteRequest) {
+        final short typeCode = undoLogDeleteRequest.getTypeCode();
+
+        final AbstractMessageProto abstractMessage = AbstractMessageProto.newBuilder().setMessageType(
+            MessageTypeProto.forNumber(typeCode)).build();
+
+        final AbstractTransactionRequestProto abstractTransactionRequestProto = AbstractTransactionRequestProto
+            .newBuilder().setAbstractMessage(
+                abstractMessage).build();
+
+        final UndoLogDeleteRequestProto undoLogDeleteRequestProto = UndoLogDeleteRequestProto
+            .newBuilder()
+            .setAbstractTransactionRequest(abstractTransactionRequestProto)
+            .setSaveDays(undoLogDeleteRequest.getSaveDays())
+            .setBranchType(BranchTypeProto.valueOf(undoLogDeleteRequest.getBranchType().name()))
+            .setResourceId(undoLogDeleteRequest.getResourceId())
+            .build();
+
+        return undoLogDeleteRequestProto;
+    }
+
+    @Override
+    public UndoLogDeleteRequest convert2Model(UndoLogDeleteRequestProto undoLogDeleteRequestProto) {
+        UndoLogDeleteRequest undoLogDeleteRequest = new UndoLogDeleteRequest();
+        undoLogDeleteRequest.setSaveDays((short)undoLogDeleteRequestProto.getSaveDays());
+        undoLogDeleteRequest.setResourceId(undoLogDeleteRequestProto.getResourceId());
+        undoLogDeleteRequest.setBranchType(BranchType.valueOf(undoLogDeleteRequestProto.getBranchType().name()));
+
+        return undoLogDeleteRequest;
+    }
+}