添加打印对tx-group传递参数的日志

Author: xlorne

transaction-dubbo/src/main/java/com/codingapi/tx/dubbo/filter/TransactionFilter.java

@@ -15,19 +15,16 @@ public class TransactionFilter implements Filter {
 
     @Override
     public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
+
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
+        String groupId = txTransactionLocal == null ? null : txTransactionLocal.getGroupId();
+        int maxTimeOut = txTransactionLocal == null ? 0 : txTransactionLocal.getMaxTimeOut();
 
+        logger.info("LCN-dubbo TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
 
         if(txTransactionLocal!=null){
-            String groupId = txTransactionLocal.getGroupId();
-            int maxTimeOut = txTransactionLocal.getMaxTimeOut();
-
             RpcContext.getContext().setAttachment("tx-group",groupId);
             RpcContext.getContext().setAttachment("tx-maxTimeOut",String.valueOf(maxTimeOut));
-
-            logger.info("LCN-dubbo TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
-        }else{
-            logger.info("LCN-dubbo TxGroup info -> groupId:null,maxTimeOut:null");
         }
 
         return invoker.invoke(invocation);

transaction-springcloud/src/main/java/com/codingapi/tx/springcloud/http/TransactionHttpRequestInterceptor.java

@@ -22,13 +22,15 @@ public class TransactionHttpRequestInterceptor implements ClientHttpRequestInter
     public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
 
         TxTransactionLocal txTransactionLocal = TxTransactionLocal.current();
-        String groupId = txTransactionLocal==null?null:txTransactionLocal.getGroupId();
+        String groupId = txTransactionLocal == null ? null : txTransactionLocal.getGroupId();
         int maxTimeOut = txTransactionLocal == null ? 0 : txTransactionLocal.getMaxTimeOut();
 
         logger.info("LCN-SpringCloud TxGroup info -> groupId:"+groupId+",maxTimeOut:"+maxTimeOut);
 
-        request.getHeaders().add("tx-group",groupId);
-        request.getHeaders().add("tx-maxTimeOut", String.valueOf(maxTimeOut));
+        if(txTransactionLocal!=null) {
+            request.getHeaders().add("tx-group", groupId);
+            request.getHeaders().add("tx-maxTimeOut", String.valueOf(maxTimeOut));
+        }
         return execution.execute(request,body);
     }
 }