类的使用
org.joyqueue.client.internal.consumer.config.ConsumerConfig

使用ConsumerConfig的程序包

程序包	说明
io.openmessaging.joyqueue.config
org.joyqueue.client.internal
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.config
org.joyqueue.client.internal.consumer.container
org.joyqueue.client.internal.consumer.interceptor
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.support

io.openmessaging.joyqueue.config中ConsumerConfig的使用

返回ConsumerConfig的io.openmessaging.joyqueue.config中的方法

限定符和类型	方法和说明
static ConsumerConfig	KeyValueConverter.convertConsumerConfig(io.openmessaging.KeyValue attributes)
static ConsumerConfig	KeyValueConverter.convertConsumerConfig(NameServerConfig nameServerConfig, io.openmessaging.KeyValue attributes)

org.joyqueue.client.internal中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal中的方法

限定符和类型	方法和说明
MessageConsumer	MessageAccessPoint.createConsumer(ConsumerConfig config)
MessagePoller	MessageAccessPoint.createPoller(ConsumerConfig config)

org.joyqueue.client.internal.consumer中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.createBroadcastPoller(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.createPartitionPoller(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, ConsumerIndexManager consumerIndexManager)

org.joyqueue.client.internal.consumer.config中ConsumerConfig的使用

返回ConsumerConfig的org.joyqueue.client.internal.consumer.config中的方法

限定符和类型	方法和说明
ConsumerConfig	ConsumerConfig.copy()

org.joyqueue.client.internal.consumer.container中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal.consumer.container中的方法

限定符和类型	方法和说明
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig) 已过时。
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager) 已过时。
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager) 已过时。
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ConsumerClientManager consumerClientManager) 已过时。
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig) 已过时。
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ConsumerClientManager consumerClientManager) 已过时。

参数类型为ConsumerConfig的org.joyqueue.client.internal.consumer.container中的构造器

构造器和说明
DefaultMessageListenerContainer(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
MessageListenerContainerWrapper(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageListenerContainer delegate)

org.joyqueue.client.internal.consumer.interceptor中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal.consumer.interceptor中的构造器

构造器和说明
ConsumerInvocation(ConsumerConfig config, String topic, NameServerConfig nameServerConfig, List<ConsumeMessage> messages, ConsumerInterceptorManager consumerInterceptorManager, ConsumerInvoker consumerInvoker)

org.joyqueue.client.internal.consumer.support中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal.consumer.support中的构造器

构造器和说明
BatchConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<BatchMessageListener> listeners)
BroadcastMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager)
DefaultMessageConsumer(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
DefaultMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
LocalConsumerIndexManager(ConsumerConfig config, ConsumerIndexManager delegate)
MessageConsumerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageConsumer delegate)
MessagePollerInner(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, MessageFetcher messageFetcher)
MessagePollerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessagePoller delegate)
OnceConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)
PartitionMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, ConsumerIndexManager consumerIndexManager)
TopicMessageConsumer(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
TopicMessageConsumer(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, ConsumerInterceptorManager consumerInterceptorManager)
TopicMessageConsumerDispatcher(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, MessagePoller messagePoller, MessageListenerManager messageListenerManager, ConsumerInterceptorManager consumerInterceptorManager)
TopicMessageConsumerScheduler(String topic, ConsumerConfig config, MessagePoller messagePoller, TopicMessageConsumerDispatcher messageConsumerDispatcher)

org.joyqueue.client.internal.support中ConsumerConfig的使用

参数类型为ConsumerConfig的org.joyqueue.client.internal.support中的方法

限定符和类型	方法和说明
MessageConsumer	DefaultMessageAccessPoint.createConsumer(ConsumerConfig config)
MessagePoller	DefaultMessageAccessPoint.createPoller(ConsumerConfig config)