接口的使用
org.joyqueue.client.internal.consumer.MessageConsumer

使用MessageConsumer的程序包

程序包	说明
io.openmessaging.joyqueue.consumer.extension
io.openmessaging.joyqueue.consumer.support
org.joyqueue.client.internal
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.support

io.openmessaging.joyqueue.consumer.extension中MessageConsumer的使用

参数类型为MessageConsumer的io.openmessaging.joyqueue.consumer.extension中的构造器

构造器和说明
ExtensionAdapter(MessageConsumer messageConsumer)

io.openmessaging.joyqueue.consumer.support中MessageConsumer的使用

参数类型为MessageConsumer的io.openmessaging.joyqueue.consumer.support中的构造器

构造器和说明
ConsumerImpl(MessageConsumer messageConsumer)

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

返回MessageConsumer的org.joyqueue.client.internal中的方法

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

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

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

限定符和类型	方法和说明
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig)
static MessageConsumer	MessageConsumerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ConsumerClientManager consumerClientManager)
static MessageConsumer	MessageConsumerFactory.create(String address, String app, String token)
static MessageConsumer	MessageConsumerFactory.create(String address, String app, String token, String region)
static MessageConsumer	MessageConsumerFactory.create(String address, String app, String token, String region, String namespace)

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

实现MessageConsumer的org.joyqueue.client.internal.consumer.support中的类

限定符和类型	类和说明
class	DefaultMessageConsumer DefaultMessageConsumer author: gaohaoxiang date: 2019/1/10
class	MessageConsumerWrapper MessageConsumerWrapper author: gaohaoxiang date: 2019/1/10

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

构造器和说明
MessageConsumerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageConsumer delegate)

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

返回MessageConsumer的org.joyqueue.client.internal.support中的方法

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