org.joyqueue.client.internal.consumer.transport

类 ConsumerClient

java.lang.Object

org.joyqueue.client.internal.consumer.transport.ConsumerClient

public class ConsumerClient
extends Object

ConsumerClient author: gaohaoxiang date: 2018/11/29

字段概要

字段

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

构造器概要

构造器

构造器和说明
ConsumerClient(Client client)

方法概要

限定符和类型	方法和说明
void	addConsumers()
void	addConsumers(Collection<String> topics, String app)
void	asyncFetchPartitionMessage(Map<String,Short> partitions, String app, int count, long timeout, CommandCallback callback)
void	asyncFetchPartitionMessage(com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout, CommandCallback callback)
void	asyncFetchTopicMessage(List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout, CommandCallback callback)
static ConsumerClient	build(Client client)
protected CommitIndexRequest	buildCommitIndexCommand(com.google.common.collect.Table<String,Short,Long> partitions, String app)
protected FetchTopicMessageRequest	buildFetchTopicMessageCommand(List<String> topics, String app, int count, long ackTimeout, long longPollTimeout)
protected FetchPartitionMessageRequest	buildPartitionTopicMessageCommand(Map<String,Short> partitions, String app, int count)
protected FetchPartitionMessageRequest	buildPartitionTopicMessageCommand(com.google.common.collect.Table<String,Short,Long> partitions, String app, int count)
void	close()
CommitAckResponse	commitAck(com.google.common.collect.Table<String,Short,List<CommitAckData>> data, String app, long timeout)
CommitIndexResponse	commitIndex(com.google.common.collect.Table<String,Short,Long> partitions, String app, long timeout)
FetchIndexResponse	fetchIndex(Map<String,List<Short>> partitions, String app, long timeout)
FetchPartitionMessageResponse	fetchPartitionMessage(Map<String,Short> partitions, String app, int count, long timeout)
FetchPartitionMessageResponse	fetchPartitionMessage(com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout)
FetchTopicMessageResponse	fetchTopicMessage(List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
TransportAttribute	getAttribute()
Client	getClient()
ClientState	getState()
void	removeConsumers(Collection<String> topics, String app)

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

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

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

ConsumerClient

public ConsumerClient(Client client)

方法详细资料

build

public static ConsumerClient build(Client client)

fetchIndex

public FetchIndexResponse fetchIndex(Map<String,List<Short>> partitions,
                                     String app,
                                     long timeout)

commitAck

public CommitAckResponse commitAck(com.google.common.collect.Table<String,Short,List<CommitAckData>> data,
                                   String app,
                                   long timeout)

asyncFetchTopicMessage

public void asyncFetchTopicMessage(List<String> topics,
                                   String app,
                                   int count,
                                   long timeout,
                                   long ackTimeout,
                                   long longPollTimeout,
                                   CommandCallback callback)

fetchTopicMessage

public FetchTopicMessageResponse fetchTopicMessage(List<String> topics,
                                                   String app,
                                                   int count,
                                                   long timeout,
                                                   long ackTimeout,
                                                   long longPollTimeout)

fetchPartitionMessage

public FetchPartitionMessageResponse fetchPartitionMessage(Map<String,Short> partitions,
                                                           String app,
                                                           int count,
                                                           long timeout)

asyncFetchPartitionMessage

public void asyncFetchPartitionMessage(Map<String,Short> partitions,
                                       String app,
                                       int count,
                                       long timeout,
                                       CommandCallback callback)

fetchPartitionMessage

public FetchPartitionMessageResponse fetchPartitionMessage(com.google.common.collect.Table<String,Short,Long> partitions,
                                                           String app,
                                                           int count,
                                                           long timeout)

asyncFetchPartitionMessage

public void asyncFetchPartitionMessage(com.google.common.collect.Table<String,Short,Long> partitions,
                                       String app,
                                       int count,
                                       long timeout,
                                       CommandCallback callback)

commitIndex

public CommitIndexResponse commitIndex(com.google.common.collect.Table<String,Short,Long> partitions,
                                       String app,
                                       long timeout)

addConsumers

public void addConsumers()

addConsumers

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

removeConsumers

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

close

public void close()

buildPartitionTopicMessageCommand

protected FetchPartitionMessageRequest buildPartitionTopicMessageCommand(Map<String,Short> partitions,
                                                                         String app,
                                                                         int count)

buildPartitionTopicMessageCommand

protected FetchPartitionMessageRequest buildPartitionTopicMessageCommand(com.google.common.collect.Table<String,Short,Long> partitions,
                                                                         String app,
                                                                         int count)

buildFetchTopicMessageCommand

protected FetchTopicMessageRequest buildFetchTopicMessageCommand(List<String> topics,
                                                                 String app,
                                                                 int count,
                                                                 long ackTimeout,
                                                                 long longPollTimeout)

buildCommitIndexCommand

protected CommitIndexRequest buildCommitIndexCommand(com.google.common.collect.Table<String,Short,Long> partitions,
                                                     String app)

getAttribute

public TransportAttribute getAttribute()

getClient

public Client getClient()

getState

public ClientState getState()