Skip to content

Commit 5ad6a3e

Browse files
authored
[ISSUE #10274] Fix ForwardMessageToDeadLetterQueue request mapping descriptor (#10275)
1 parent c083052 commit 5ad6a3e

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import apache.rocketmq.v2.AckMessageRequest;
2121
import apache.rocketmq.v2.ChangeInvisibleDurationRequest;
2222
import apache.rocketmq.v2.EndTransactionRequest;
23-
import apache.rocketmq.v2.ForwardMessageToDeadLetterQueueResponse;
23+
import apache.rocketmq.v2.ForwardMessageToDeadLetterQueueRequest;
2424
import apache.rocketmq.v2.HeartbeatRequest;
2525
import apache.rocketmq.v2.NotifyClientTerminationRequest;
2626
import apache.rocketmq.v2.QueryAssignmentRequest;
@@ -44,7 +44,7 @@ public class RequestMapping {
4444
put(QueryAssignmentRequest.getDescriptor().getFullName(), RequestCode.GET_ROUTEINFO_BY_TOPIC);
4545
put(ReceiveMessageRequest.getDescriptor().getFullName(), RequestCode.PULL_MESSAGE);
4646
put(AckMessageRequest.getDescriptor().getFullName(), RequestCode.UPDATE_CONSUMER_OFFSET);
47-
put(ForwardMessageToDeadLetterQueueResponse.getDescriptor().getFullName(), RequestCode.CONSUMER_SEND_MSG_BACK);
47+
put(ForwardMessageToDeadLetterQueueRequest.getDescriptor().getFullName(), RequestCode.CONSUMER_SEND_MSG_BACK);
4848
put(EndTransactionRequest.getDescriptor().getFullName(), RequestCode.END_TRANSACTION);
4949
put(NotifyClientTerminationRequest.getDescriptor().getFullName(), RequestCode.UNREGISTER_CLIENT);
5050
put(ChangeInvisibleDurationRequest.getDescriptor().getFullName(), RequestCode.CONSUMER_SEND_MSG_BACK);

0 commit comments

Comments
 (0)