| 程序包 | 说明 |
|---|---|
| org.joyqueue.client.internal.consumer | |
| org.joyqueue.client.internal.consumer.support |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageFetcher |
MessageFetcherFactory.create(ConsumerClientManager consumerClientManager,
FetcherConfig config) |
static MessageFetcher |
MessageFetcherFactory.create(NameServerConfig nameServerConfig) |
static MessageFetcher |
MessageFetcherFactory.create(NameServerConfig nameServerConfig,
FetcherConfig config) |
static MessageFetcher |
MessageFetcherFactory.create(String address,
String app,
String token) |
static MessageFetcher |
MessageFetcherFactory.create(String address,
String app,
String token,
String region) |
static MessageFetcher |
MessageFetcherFactory.create(String address,
String app,
String token,
String region,
String namespace) |
static MessageFetcher |
MessageFetcherFactory.create(TransportConfig transportConfig,
NameServerConfig nameServerConfig,
FetcherConfig config) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DefaultMessageFetcher
DefaultMessageFetcher
author: gaohaoxiang
date: 2018/12/7
|
class |
MessageFetcherWrapper
MessageFetcherWrapper
author: gaohaoxiang
date: 2018/12/27
|
| 构造器和说明 |
|---|
MessageFetcherWrapper(ConsumerClientManager consumerClientManager,
MessageFetcher delegate) |
MessagePollerInner(ConsumerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ConsumerClientManager consumerClientManager,
MessageFetcher messageFetcher) |
Copyright © 2020 Joyqueue Community. All rights reserved.