[rocketmq-clients] branch master updated: Java: Fix typo of repeated endpoint

[aaronai]

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 <yangkun....@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;