org.joyqueue.client.internal.producer.transport

类 ProducerClient

java.lang.Object

org.joyqueue.client.internal.producer.transport.ProducerClient

public class ProducerClient
extends Object

ProducerClient author: gaohaoxiang date: 2018/11/29

构造器概要

构造器

构造器和说明
ProducerClient(Client client)

方法概要

限定符和类型	方法和说明
void	addProducers()
void	addProducers(Collection<String> topics, String app)
void	asyncProduceMessage(String app, Map<String,ProduceMessageData> messages, long timeout, CommandCallback callback)
static ProducerClient	build(Client client)
void	close()
FetchProduceFeedbackResponse	fetchFeedback(String topic, String app, TxStatus txStatus, int count, long longPollTimeout, long timeout)
TransportAttribute	getAttribute()
Client	getClient()
ClientState	getState()
ProduceMessageResponse	produceMessage(String app, Map<String,ProduceMessageData> messages, long timeout)
ProduceMessageCommitResponse	produceMessageCommit(String topic, String app, String txId, long timeout)
void	produceMessageOneway(String app, Map<String,ProduceMessageData> messages, long timeout)
ProduceMessagePrepareResponse	produceMessagePrepare(String topic, String app, long sequence, String transactionId, long transactionTimeout, long timeout)
ProduceMessageRollbackResponse	produceMessageRollback(String topic, String app, String txId, long timeout)
void	removeProducers(Collection<String> topics, String app)

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

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

构造器详细资料

ProducerClient

public ProducerClient(Client client)

方法详细资料

build

public static ProducerClient build(Client client)

produceMessage

public ProduceMessageResponse produceMessage(String app,
                                             Map<String,ProduceMessageData> messages,
                                             long timeout)

produceMessageOneway

public void produceMessageOneway(String app,
                                 Map<String,ProduceMessageData> messages,
                                 long timeout)

asyncProduceMessage

public void asyncProduceMessage(String app,
                                Map<String,ProduceMessageData> messages,
                                long timeout,
                                CommandCallback callback)

produceMessagePrepare

public ProduceMessagePrepareResponse produceMessagePrepare(String topic,
                                                           String app,
                                                           long sequence,
                                                           String transactionId,
                                                           long transactionTimeout,
                                                           long timeout)

produceMessageCommit

public ProduceMessageCommitResponse produceMessageCommit(String topic,
                                                         String app,
                                                         String txId,
                                                         long timeout)

produceMessageRollback

public ProduceMessageRollbackResponse produceMessageRollback(String topic,
                                                             String app,
                                                             String txId,
                                                             long timeout)

fetchFeedback

public FetchProduceFeedbackResponse fetchFeedback(String topic,
                                                  String app,
                                                  TxStatus txStatus,
                                                  int count,
                                                  long longPollTimeout,
                                                  long timeout)

addProducers

public void addProducers()

addProducers

public void addProducers(Collection<String> topics,
                         String app)

removeProducers

public void removeProducers(Collection<String> topics,
                            String app)

close

public void close()

getAttribute

public TransportAttribute getAttribute()

getClient

public Client getClient()

getState

public ClientState getState()