Add ExcludeFromJacocoGeneratedReport annotation (apache#441)

java/client/src/main/java/org/apache/rocketmq/client/java/impl/Settings.java

@@ -20,6 +20,7 @@
 import com.google.common.base.MoreObjects;
 import java.time.Duration;
 import org.apache.rocketmq.client.java.misc.ClientId;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.retry.RetryPolicy;
 import org.apache.rocketmq.client.java.route.Endpoints;
 
@@ -51,6 +52,7 @@ public RetryPolicy getRetryPolicy() {
         return retryPolicy;
     }
 
+    @ExcludeFromJacocoGeneratedReport
     @Override
     public String toString() {
         return MoreObjects.toStringHelper(this)

java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java

@@ -56,6 +56,7 @@
 import org.apache.rocketmq.client.java.message.GeneralMessageImpl;
 import org.apache.rocketmq.client.java.message.MessageViewImpl;
 import org.apache.rocketmq.client.java.misc.ClientId;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.retry.RetryPolicy;
 import org.apache.rocketmq.client.java.route.Endpoints;
 import org.apache.rocketmq.client.java.route.MessageQueueImpl;
@@ -637,6 +638,7 @@ public long getCachedMessageBytes() {
         return cachedMessagesBytes.get();
     }
 
+    @ExcludeFromJacocoGeneratedReport
     public void doStats() {
         final long receptionTimes = this.receptionTimes.getAndSet(0);
         final long receivedMessagesQuantity = this.receivedMessagesQuantity.getAndSet(0);

java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java

@@ -68,6 +68,7 @@
 import org.apache.rocketmq.client.java.message.MessageViewImpl;
 import org.apache.rocketmq.client.java.message.protocol.Resource;
 import org.apache.rocketmq.client.java.metrics.GaugeObserver;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.misc.ExecutorServices;
 import org.apache.rocketmq.client.java.misc.ThreadFactoryImpl;
 import org.apache.rocketmq.client.java.retry.RetryPolicy;
@@ -541,6 +542,7 @@ public void onFailure(Throwable t) {
         return future;
     }
 
+    @ExcludeFromJacocoGeneratedReport
     @Override
     public void doStats() {
         final long receptionTimes = this.receptionTimes.getAndSet(0);

java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushSubscriptionSettings.java

@@ -34,6 +34,7 @@
 import org.apache.rocketmq.client.java.impl.UserAgent;
 import org.apache.rocketmq.client.java.message.protocol.Resource;
 import org.apache.rocketmq.client.java.misc.ClientId;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.retry.CustomizedBackoffRetryPolicy;
 import org.apache.rocketmq.client.java.retry.ExponentialBackoffRetryPolicy;
 import org.apache.rocketmq.client.java.route.Endpoints;
@@ -124,6 +125,7 @@ public void sync(apache.rocketmq.v2.Settings settings) {
         }
     }
 
+    @ExcludeFromJacocoGeneratedReport
     @Override
     public String toString() {
         return MoreObjects.toStringHelper(this)

java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleSubscriptionSettings.java

@@ -33,6 +33,7 @@
 import org.apache.rocketmq.client.java.impl.UserAgent;
 import org.apache.rocketmq.client.java.message.protocol.Resource;
 import org.apache.rocketmq.client.java.misc.ClientId;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.route.Endpoints;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -93,6 +94,7 @@ public void sync(apache.rocketmq.v2.Settings settings) {
         }
     }
 
+    @ExcludeFromJacocoGeneratedReport
     @Override
     public String toString() {
         return MoreObjects.toStringHelper(this)

java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/PublishingSettings.java

@@ -28,6 +28,7 @@
 import org.apache.rocketmq.client.java.impl.Settings;
 import org.apache.rocketmq.client.java.impl.UserAgent;
 import org.apache.rocketmq.client.java.misc.ClientId;
+import org.apache.rocketmq.client.java.misc.ExcludeFromJacocoGeneratedReport;
 import org.apache.rocketmq.client.java.retry.ExponentialBackoffRetryPolicy;
 import org.apache.rocketmq.client.java.retry.RetryPolicy;
 import org.apache.rocketmq.client.java.route.Endpoints;
@@ -85,6 +86,7 @@ public void sync(apache.rocketmq.v2.Settings settings) {
         this.maxBodySizeBytes = publishing.getMaxBodySize();
     }
 
+    @ExcludeFromJacocoGeneratedReport
     @Override
     public String toString() {
         return MoreObjects.toStringHelper(this)

java/client/src/main/java/org/apache/rocketmq/client/java/misc/ExcludeFromJacocoGeneratedReport.java

@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.rocketmq.client.java.misc;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * This annotation is used to exclude a specific method from being included in the code coverage
+ * report generated by Jacoco. It should be applied at the method level, and indicates that the
+ * annotated method should be excluded from the code coverage report. The annotation is implemented
+ * with a retention policy of RUNTIME, allowing it to be read at runtime. The annotation target is
+ * set to METHOD, indicating that it can only be applied to methods.
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+public @interface ExcludeFromJacocoGeneratedReport {
+}