diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java index 2147285414c60eed7a98a3f6e2bbaa7788c8166e..a7e433afc1a7d07c7be8a7f3fd447e07973b0f60 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java @@ -68,7 +68,7 @@ public class AsyncSendWithMessageQueueIT extends BaseConf { producer.clearMsg(); consumer.clearMsg(); - producer.getSuccessSendResult().clear(); + producer.getSuccessSendResult().clear(); mq = new MessageQueue(topic, broker2Name, queueId); producer.asyncSend(msgSize, mq); producer.waitForResponse(10 * 1000);