commit 1b36f32d12ccdcf2c325332294157f481177db6a
author lipenghui <penghui@apache.org> Thu Jan 06 08:48:51 2022 +0800
committer GitHub <noreply@github.com> Thu Jan 06 08:48:51 2022 +0800
tree 891f532bd470a5233e73054eb53ca946f0ae606d
parent 937131a7003d94031b720b3c0d3d64a9bd602bc9

Change level log to debug for broker interceptor testing (#13604)

pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java
index 943c567..da4d4f0 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java
@@ -66,16 +66,20 @@
     }
 
     @Override
-    public void onConnectionCreated(ServerCnx cnx){
-        log.info("Connection created {}", cnx);
+    public void onConnectionCreated(ServerCnx cnx) {
+        if (log.isDebugEnabled()) {
+            log.debug("Connection created {}", cnx);
+        }
         connectionCreationCount++;
     }
 
     @Override
     public void producerCreated(ServerCnx cnx, Producer producer,
-                                Map<String, String> metadata){
-        log.info("Producer created with name={}, id={}",
-            producer.getProducerName(), producer.getProducerId());
+                                Map<String, String> metadata) {
+        if (log.isDebugEnabled()) {
+            log.debug("Producer created with name={}, id={}",
+                    producer.getProducerName(), producer.getProducerId());
+        }
         producerCount++;
     }
 
@@ -83,8 +87,10 @@
     public void consumerCreated(ServerCnx cnx,
                                  Consumer consumer,
                                  Map<String, String> metadata) {
-        log.info("Consumer created with name={}, id={}",
-            consumer.consumerName(), consumer.consumerId());
+        if (log.isDebugEnabled()) {
+            log.debug("Consumer created with name={}, id={}",
+                    consumer.consumerName(), consumer.consumerId());
+        }
         consumerCount++;
     }
 
@@ -92,16 +98,20 @@
     public void messageProduced(ServerCnx cnx, Producer producer, long startTimeNs, long ledgerId,
                                  long entryId,
                                  Topic.PublishContext publishContext) {
-        log.info("Message published topic={}, producer={}",
-            producer.getTopic().getName(), producer.getProducerName());
+        if (log.isDebugEnabled()) {
+            log.debug("Message published topic={}, producer={}",
+                    producer.getTopic().getName(), producer.getProducerName());
+        }
         messageCount++;
     }
 
     @Override
     public void messageDispatched(ServerCnx cnx, Consumer consumer, long ledgerId,
                                    long entryId, ByteBuf headersAndPayload) {
-        log.info("Message dispatched topic={}, consumer={}",
-            consumer.getSubscription().getTopic().getName(), consumer.consumerName());
+        if (log.isDebugEnabled()) {
+            log.debug("Message dispatched topic={}, consumer={}",
+                    consumer.getSubscription().getTopic().getName(), consumer.consumerName());
+        }
         messageDispatchCount++;
     }
 
@@ -116,14 +126,18 @@
                                   Entry entry,
                                   long[] ackSet,
                                   MessageMetadata msgMetadata) {
-        log.debug("Send message to topic {}, subscription {}",
-            subscription.getTopic(), subscription.getName());
+        if (log.isDebugEnabled()) {
+            log.debug("Send message to topic {}, subscription {}",
+                    subscription.getTopic(), subscription.getName());
+        }
         beforeSendCount++;
     }
 
     @Override
     public void onPulsarCommand(BaseCommand command, ServerCnx cnx) {
-        log.debug("[{}] On [{}] Pulsar command", count, command.getType().name());
+        if (log.isDebugEnabled()) {
+            log.debug("[{}] On [{}] Pulsar command", count, command.getType().name());
+        }
         count ++;
     }
 
@@ -135,13 +149,17 @@
     @Override
     public void onWebserviceRequest(ServletRequest request) {
         count ++;
-        log.debug("[{}] On [{}] Webservice request", count, ((HttpServletRequest)request).getRequestURL().toString());
+        if (log.isDebugEnabled()) {
+            log.debug("[{}] On [{}] Webservice request", count, ((HttpServletRequest) request).getRequestURL().toString());
+        }
     }
 
     @Override
     public void onWebserviceResponse(ServletRequest request, ServletResponse response) {
         count ++;
-        log.debug("[{}] On [{}] Webservice response {}", count, ((HttpServletRequest)request).getRequestURL().toString(), response);
+        if (log.isDebugEnabled()) {
+            log.debug("[{}] On [{}] Webservice response {}", count, ((HttpServletRequest) request).getRequestURL().toString(), response);
+        }
         if (response instanceof Response) {
             Response res = (Response) response;
             responseList.add(new ResponseEvent(res.getHttpChannel().getRequest().getRequestURI(), res.getStatus()));