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 9fe26eb8b39822f6cebed9e4c81b187331733323..a89d3fbc5a3e702a11675f786f52e19e75e45b60 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 @@ -17,11 +17,8 @@ package org.apache.rocketmq.client.producer; import java.util.concurrent.ExecutorService; -import org.apache.rocketmq.client.Validators; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.common.message.Message; -import org.apache.rocketmq.common.message.MessageAccessor; -import org.apache.rocketmq.common.message.MessageConst; import org.apache.rocketmq.remoting.RPCHook; public class TransactionMQProducer extends DefaultMQProducer {