You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/05/22 11:49:25 UTC
[rocketmq] branch develop updated: remove unused code
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new b155068 remove unused code
new 4a9f7a8 Merge pull request #2002 from rushsky518/unused_code
b155068 is described below
commit b1550689c5d8647d9b6902269bb0466e19a7bb5a
Author: rushsky518 <ru...@163.com>
AuthorDate: Sun May 17 14:53:25 2020 +0800
remove unused code
---
.../org/apache/rocketmq/client/impl/factory/MQClientInstance.java | 6 ------
1 file changed, 6 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index bbd2eec..886203f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -17,7 +17,6 @@
package org.apache.rocketmq.client.impl.factory;
import java.io.UnsupportedEncodingException;
-import java.net.DatagramSocket;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
@@ -118,7 +117,6 @@ public class MQClientInstance {
private final ConsumerStatsManager consumerStatsManager;
private final AtomicLong sendHeartbeatTimesTotal = new AtomicLong(0);
private ServiceState serviceState = ServiceState.CREATE_JUST;
- private DatagramSocket datagramSocket;
private Random random = new Random();
public MQClientInstance(ClientConfig clientConfig, int instanceIndex, String clientId) {
@@ -854,10 +852,6 @@ public class MQClientInstance {
this.mQClientAPIImpl.shutdown();
this.rebalanceService.shutdown();
- if (this.datagramSocket != null) {
- this.datagramSocket.close();
- this.datagramSocket = null;
- }
MQClientManager.getInstance().removeClientFactory(this.clientId);
log.info("the client factory [{}] shutdown OK", this.clientId);
break;