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/19 01:37:06 UTC
[rocketmq-clients] 01/01: 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
commit 2ce7bb6fdfc943e6c8169694f127140ba9b41e64
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Sat Jun 18 18:47:13 2022 +0800
Java: Fix typo of repeated endpoint
---
.../apache/rocketmq/client/java/impl/producer/ProducerImpl.java | 7 +++----
1 file changed, 3 insertions(+), 4 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..665a076 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;
@@ -516,8 +515,8 @@ class ProducerImpl extends ClientImpl implements Producer {
if (MessageType.TRANSACTION.equals(messageType)) {
future.setException(t);
LOGGER.error("Failed to send transactional message finally, maxAttempts=1, attempt={}, " +
- "topic={}, messageId(s), endpoints={}, clientId={}", attempt, topic, messageIds, endpoints,
- clientId, t);
+ "topic={}, messageId(s)={}, endpoints={}, clientId={}", attempt, topic, messageIds,
+ endpoints, clientId, t);
return;
}
// Try to do more attempts.