From 83edc6330396faf19af4008302923049304c865b Mon Sep 17 00:00:00 2001 From: TheR1sing3un Date: Thu, 19 Oct 2023 18:32:36 +0800 Subject: [PATCH] fix(proxy): fix DLQServiceTest#send_group_not_allowed_dlq 1. fix DLQServiceTest#send_group_not_allowed_dlq Signed-off-by: TheR1sing3un --- .../com/automq/rocketmq/proxy/service/DLQServiceTest.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java b/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java index 2e0153ada..6ff03161e 100644 --- a/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java +++ b/proxy/src/test/java/com/automq/rocketmq/proxy/service/DLQServiceTest.java @@ -148,6 +148,12 @@ public void send_group_not_allowed_dlq() { .setName(DLQ_TOPIC_NAME) .addAcceptMessageTypes(MessageType.TRANSACTION) .build(); + consumerGroup = ConsumerGroup.newBuilder() + .setGroupId(CONSUMER_GROUP_ID) + .setName(CONSUMER_GROUP_NAME) + .setGroupType(GroupType.GROUP_TYPE_STANDARD) + .setDeadLetterTopicId(DLQ_TOPIC_ID) + .build(); Mockito.doReturn(CompletableFuture.completedFuture(dlqTopic)) .when(metadataService).topicOf(DLQ_TOPIC_ID); Mockito.doReturn(CompletableFuture.completedFuture(consumerGroup))