You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/06/18 10:47:21 UTC
[rocketmq-clients] branch master updated: Java: Fix typo of repeated endpoint
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 1b75f42 Java: Fix typo of repeated endpoint
1b75f42 is described below
commit 1b75f42e6681081f5355e92a757a5bebbfd0340a
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Sat Jun 18 18:47:13 2022 +0800
Java: Fix typo of repeated endpoint
---
.../org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
index 7c3d658..be754eb 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
@@ -132,8 +132,7 @@ class ProducerImpl extends ClientImpl implements Producer {
messageView = MessageViewImpl.fromProtobuf(command.getOrphanedTransactionalMessage(), mq);
} catch (Throwable t) {
LOGGER.error("[Bug] Failed to decode message during orphaned transaction message recovery, messageId={}, "
- + "transactionId={}, endpoints={}, clientId={}", messageId, transactionId, endpoints, endpoints,
- clientId, t);
+ + "transactionId={}, endpoints={}, clientId={}", messageId, transactionId, endpoints, clientId, t);
return;
}
ListenableFuture<TransactionResolution> future;