Merge branch 'bugfix/remove_connect_retry'

Author: mike.wq

app-stream-api/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

app-stream-client/pom.xml

@@ -4,13 +4,13 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-client</artifactId>
     <packaging>jar</packaging>
-    <version>1.3.2</version>
+    <version>1.3.3</version>
     <name>app-stream-client</name>
 
     <dependencies>

app-stream-network/app-stream-network-api/pom.xml

@@ -4,12 +4,12 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-network-api</artifactId>
-    <version>1.3.2</version>
+    <version>1.3.3</version>
     <packaging>jar</packaging>
 
     <name>app-stream-network-api</name>

app-stream-network/app-stream-network-core/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/app-stream-network-core/src/main/java/com/dingtalk/open/app/stream/network/core/DefaultSessionPool.java

@@ -165,8 +165,7 @@ public void run() {
                             closeSession(previous.getId());
                         }
                     }
-                    Session session = new RetryRunner<Session>(MAX_RETRY_COUNT, new ExponentialBackoffPolicy())
-                            .run(() -> Connector.connect(connection, new TransportConnectionListener(), connectionTimeout, connectionTTL, keepAliveIdle));
+                    Session session = Connector.connect(connection, new TransportConnectionListener(), connectionTimeout, connectionTTL, keepAliveIdle);
                     if (session == null) {
                         return;
                     }

app-stream-network/app-stream-network-rsocket/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/app-stream-network-ws/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/app-stream-network-ws/src/main/java/com/dingtalk/open/app/stream/network/ws/KeepAliveHandler.java

@@ -31,14 +31,13 @@
 public class KeepAliveHandler extends SimpleChannelInboundHandler<PongWebSocketFrame> {
     private static final InternalLogger LOGGER = InternalLoggerFactory.getLogger(KeepAliveHandler.class);
     private final Duration timeout;
-    private final HashedWheelTimer timer;
+    private final  static HashedWheelTimer TIMER = new HashedWheelTimer();
     private Channel channel;
     private final Map<String, Timeout> timeouts;
     private final AtomicBoolean active;
 
     public KeepAliveHandler(Duration timeout) {
         this.timeout = timeout;
-        this.timer = new HashedWheelTimer();
         this.active = new AtomicBoolean(false);
         this.timeouts = new ConcurrentHashMap<>();
     }
@@ -82,7 +81,6 @@ private void shutdown() {
             entry.getValue().cancel();
             it.remove();
         }
-        this.timer.stop();
     }
 
     private class PingTask implements Runnable {
@@ -96,7 +94,7 @@ public void run() {
             PingWebSocketFrame frame = new PingWebSocketFrame(byteBuf);
             channel.writeAndFlush(frame).addListener(future -> {
                 if (future.isSuccess()) {
-                    Timeout pingTimeout = timer.newTimeout(timeout -> {
+                    Timeout pingTimeout = TIMER.newTimeout(timeout -> {
                         LOGGER.warn("[DingTalk] connection ping timeout, channel is closing");
                         timeouts.remove(seq);
                         channel.close();

app-stream-network/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <packaging>pom</packaging>

app-stream-protocol/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.3.2</version>
+        <version>1.3.3</version>
     </parent>
 
     <artifactId>app-stream-protocol</artifactId>