Skip to content

Commit 4a4d8a5

Browse files
committed
client enhancement
1 parent 65f244a commit 4a4d8a5

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumer/SubscriptionManager.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.apache.commons.collections4.CollectionUtils;
3131

3232
import java.util.ArrayList;
33-
import java.util.Date;
3433
import java.util.HashMap;
3534
import java.util.List;
3635
import java.util.Map;
@@ -94,7 +93,7 @@ public void registerClient(final ClientInfo clientInfo, final String consumerGro
9493
client.setUrl(url);
9594
return client;
9695
});
97-
clientInner.setLastUpTime(new Date());
96+
clientInner.reNewLastUpTime();
9897
if (!localClients.contains(clientInner)) {
9998
localClients.add(clientInner);
10099
}

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/Client.java

+4
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,10 @@ public Date getLastUpTime() {
131131
return lastUpTime;
132132
}
133133

134+
public void reNewLastUpTime() {
135+
this.setLastUpTime(new Date());
136+
}
137+
134138
@Override
135139
public String toString() {
136140
StringBuilder sb = new StringBuilder();

0 commit comments

Comments
 (0)