mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
Remove annotation
This commit is contained in:
@@ -134,7 +134,6 @@ public class GrpcClientChannel extends ProxyChannel {
|
||||
.setRecoverOrphanedTransactionCommand(RecoverOrphanedTransactionCommand.newBuilder()
|
||||
.setTransactionId(transactionData.getTransactionId())
|
||||
.setMessage(GrpcConverter.getInstance().buildMessage(messageExt))
|
||||
// .setMessageQueue(GrpcConverter.getInstance().buildMessageQueue(messageExt, transactionData.getBrokerName()))
|
||||
.build())
|
||||
.build());
|
||||
responseFuture.complete(null);
|
||||
|
||||
@@ -678,8 +678,6 @@ public class GrpcBaseIT extends BaseConf {
|
||||
}
|
||||
|
||||
public void assertRecoverOrphanedTransactionCommand(RecoverOrphanedTransactionCommand command, String messageId) {
|
||||
// assertThat(command.getOrphanedTransactionalMessage().getSystemProperties().getMessageId())
|
||||
// .isEqualTo(messageId);
|
||||
assertThat(command.getTransactionId()).isNotBlank();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user