org.joyqueue.client.internal.producer.feedback

类 TxFeedbackDispatcher

java.lang.Object

org.joyqueue.client.internal.producer.feedback.TxFeedbackDispatcher

public class TxFeedbackDispatcher
extends Object

TxFeedbackDispatcher author: gaohaoxiang date: 2018/12/24

字段概要

字段

限定符和类型	字段和说明
protected static org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
TxFeedbackDispatcher(TxFeedbackConfig config, String topic, TxFeedbackCallback txFeedbackCallback, MessageSender messageSender, ClusterManager clusterManager)

方法概要

限定符和类型	方法和说明
void	dispatch()
protected void	doConfirm(BrokerNode brokerNode, TopicMetadata topicMetadata, FeedbackData feedbackData)
protected void	doFeedback(TopicMetadata topicMetadata, BrokerNode brokerNode)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

TxFeedbackDispatcher

public TxFeedbackDispatcher(TxFeedbackConfig config,
                            String topic,
                            TxFeedbackCallback txFeedbackCallback,
                            MessageSender messageSender,
                            ClusterManager clusterManager)

方法详细资料

dispatch

public void dispatch()

doFeedback

protected void doFeedback(TopicMetadata topicMetadata,
                          BrokerNode brokerNode)

doConfirm

protected void doConfirm(BrokerNode brokerNode,
                         TopicMetadata topicMetadata,
                         FeedbackData feedbackData)