diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
index a89d3fbc5a3e702a11675f786f52e19e75e45b60..8f6428b29c2ae700547d0b082a8d13d608e35bd1 100644
--- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
@@ -31,7 +31,6 @@ public class TransactionMQProducer extends DefaultMQProducer {
private TransactionListener transactionListener;
-
public TransactionMQProducer() {
}
@@ -55,9 +54,9 @@ public class TransactionMQProducer extends DefaultMQProducer {
this.defaultMQProducerImpl.destroyTransactionEnv();
}
-
/**
- * This method will be removed in the version 5.0.0, method sendMessageInTransaction(Message,Object)
} is recommended.
+ * This method will be removed in the version 5.0.0, method sendMessageInTransaction(Message,Object)
}
+ * is recommended.
*/
@Override
@Deprecated
@@ -71,7 +70,8 @@ public class TransactionMQProducer extends DefaultMQProducer {
}
@Override
- public TransactionSendResult sendMessageInTransaction(final Message msg, final Object arg) throws MQClientException {
+ public TransactionSendResult sendMessageInTransaction(final Message msg,
+ final Object arg) throws MQClientException {
if (null == this.transactionListener) {
throw new MQClientException("TransactionListener is null", null);
}