open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace InternalLogger of RocketMQ by Slf4j Logger (#7873) 

Fixes #7872
This commit is contained in:
Aaron Ai 2023-02-22 15:38:19 +08:00 committed by GitHub
parent 335e36d6e4
commit 8a7e8a8ca2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclient/v4_8/base/IntegrationTestBase.java
View File

@ -22,17 +22,16 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.apache.rocketmq.broker.BrokerController;
import org.apache.rocketmq.common.BrokerConfig;
import org.apache.rocketmq.common.namesrv.NamesrvConfig;
import org.apache.rocketmq.logging.InternalLogger;
import org.apache.rocketmq.logging.InternalLoggerFactory;
import org.apache.rocketmq.namesrv.NamesrvController;
import org.apache.rocketmq.remoting.netty.NettyClientConfig;
import org.apache.rocketmq.remoting.netty.NettyServerConfig;
import org.apache.rocketmq.store.config.MessageStoreConfig;
import org.junit.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public final class IntegrationTestBase {
public static final InternalLogger logger =
InternalLoggerFactory.getLogger(IntegrationTestBase.class);
public static final Logger logger = LoggerFactory.getLogger(IntegrationTestBase.class);
static final String BROKER_NAME_PREFIX = "TestBrokerName_";
static final AtomicInteger BROKER_INDEX = new AtomicInteger(0);