You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/17 15:58:44 UTC
[rocketmq] branch develop updated: [ISSUE #4123] Explicit type argument can be replaced with <> for RouteInfoManager (#4124)
This is an automated email from the ASF dual-hosted git repository.
yuzhou 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 50e314eb8 [ISSUE #4123] Explicit type argument can be replaced with <> for RouteInfoManager (#4124)
50e314eb8 is described below
commit 50e314eb8ada23283dcdbb261766183c90fd435c
Author: 李晓双 Li Xiao Shuang <64...@qq.com>
AuthorDate: Sun Apr 17 23:58:38 2022 +0800
[ISSUE #4123] Explicit type argument can be replaced with <> for RouteInfoManager (#4124)
* Explicit type argument can be replaced with <> for RouteInfoManager
* Explicit type argument can be replaced with <> for RouteInfoManager
---
.../rocketmq/namesrv/routeinfo/RouteInfoManager.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
index 2069f9674..12cc66f57 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
@@ -61,11 +61,11 @@ public class RouteInfoManager {
private final HashMap<String/* brokerAddr */, List<String>/* Filter Server */> filterServerTable;
public RouteInfoManager() {
- this.topicQueueTable = new HashMap<String, Map<String, QueueData>>(1024);
- this.brokerAddrTable = new HashMap<String, BrokerData>(128);
- this.clusterAddrTable = new HashMap<String, Set<String>>(32);
- this.brokerLiveTable = new HashMap<String, BrokerLiveInfo>(256);
- this.filterServerTable = new HashMap<String, List<String>>(256);
+ this.topicQueueTable = new HashMap<>(1024);
+ this.brokerAddrTable = new HashMap<>(128);
+ this.clusterAddrTable = new HashMap<>(32);
+ this.brokerLiveTable = new HashMap<>(256);
+ this.filterServerTable = new HashMap<>(256);
}
public ClusterInfo getAllClusterInfo() {
@@ -120,7 +120,7 @@ public class RouteInfoManager {
Set<String> brokerNames = this.clusterAddrTable.get(clusterName);
if (null == brokerNames) {
- brokerNames = new HashSet<String>();
+ brokerNames = new HashSet<>();
this.clusterAddrTable.put(clusterName, brokerNames);
}
brokerNames.add(brokerName);
@@ -130,7 +130,7 @@ public class RouteInfoManager {
BrokerData brokerData = this.brokerAddrTable.get(brokerName);
if (null == brokerData) {
registerFirst = true;
- brokerData = new BrokerData(clusterName, brokerName, new HashMap<Long, String>());
+ brokerData = new BrokerData(clusterName, brokerName, new HashMap<>());
this.brokerAddrTable.put(brokerName, brokerData);
}
Map<Long, String> brokerAddrsMap = brokerData.getBrokerAddrs();
@@ -383,11 +383,11 @@ public class RouteInfoManager {
TopicRouteData topicRouteData = new TopicRouteData();
boolean foundQueueData = false;
boolean foundBrokerData = false;
- Set<String> brokerNameSet = new HashSet<String>();
- List<BrokerData> brokerDataList = new LinkedList<BrokerData>();
+ Set<String> brokerNameSet = new HashSet<>();
+ List<BrokerData> brokerDataList = new LinkedList<>();
topicRouteData.setBrokerDatas(brokerDataList);
- HashMap<String, List<String>> filterServerMap = new HashMap<String, List<String>>();
+ HashMap<String, List<String>> filterServerMap = new HashMap<>();
topicRouteData.setFilterServerTable(filterServerMap);
try {