opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] Add className in createChannel

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:29:12 +08:00
parent caaadca11c
commit 3036cf421d
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/channel/ChannelManager.java
+9 -1
View File
@@ -50,7 +50,7 @@ public class ChannelManager {
}
public <T extends SimpleChannel> T createChannel(Supplier<T> creator, Class<T> clazz) {
return createChannel(anonymousChannelId(), creator, clazz);
return createChannel(anonymousChannelId(clazz.getName()), creator, clazz);
}
public <T extends SimpleChannel> T createChannel(String clientId, Supplier<T> creator, Class<T> clazz) {
@@ -96,6 +96,14 @@ public class ChannelManager {
return clientHost + "@" + localAddress;
}
private String anonymousChannelId(String className) {
final String clientHost = InterceptorConstants.METADATA.get(Context.current())
.get(InterceptorConstants.REMOTE_ADDRESS);
final String localAddress = InterceptorConstants.METADATA.get(Context.current())
.get(InterceptorConstants.LOCAL_ADDRESS);
return className + "@" + clientHost + "@" + localAddress;
}
public static SimpleChannel createSimpleChannelDirectly() {
final String clientHost = InterceptorConstants.METADATA.get(Context.current())
.get(InterceptorConstants.REMOTE_ADDRESS);