You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2019/12/26 05:22:39 UTC
[GitHub] [rocketmq-externals] lnfdxwl opened a new issue #502: 11,
644 instances of "org.apache.rocketmq.remoting.netty.NettyRemotingClient"
lnfdxwl opened a new issue #502: 11,644 instances of "org.apache.rocketmq.remoting.netty.NettyRemotingClient"
URL: https://github.com/apache/rocketmq-externals/issues/502
org.apache.rocketmq.console.service.client.MQAdminInstance#initMQAdminInstance
public static void initMQAdminInstance(long timeoutMillis) throws MQClientException {
Integer nowCount = INIT_COUNTER.get();
if (nowCount == null) {
DefaultMQAdminExt defaultMQAdminExt;
if (timeoutMillis > 0) {
defaultMQAdminExt = new DefaultMQAdminExt(timeoutMillis);
}
else {
defaultMQAdminExt = new DefaultMQAdminExt();
}
defaultMQAdminExt.setInstanceName(Long.toString(System.currentTimeMillis()));
defaultMQAdminExt.start();
MQ_ADMIN_EXT_THREAD_LOCAL.set(defaultMQAdminExt);
INIT_COUNTER.set(1);
}
else {
INIT_COUNTER.set(nowCount + 1);
}
}
defaultMQAdminExt.setInstanceName(Long.toString(System.currentTimeMillis()));
this code
Cause produces a lot of NettyRemotingClient, is this a bug?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services