接口的使用
org.joyqueue.client.internal.producer.MessageProducer

使用MessageProducer的程序包

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

io.openmessaging.joyqueue.producer.extension中MessageProducer的使用

参数类型为MessageProducer的io.openmessaging.joyqueue.producer.extension中的构造器

构造器和说明
ExtensionAdapter(MessageProducer messageProducer)

io.openmessaging.joyqueue.producer.support中MessageProducer的使用

参数类型为MessageProducer的io.openmessaging.joyqueue.producer.support中的方法

限定符和类型	方法和说明
protected TransactionMessageProducer	TransactionalResultAdapter.prepare(io.openmessaging.message.Message message, String transactionId, MessageProducer messageProducer)

参数类型为MessageProducer的io.openmessaging.joyqueue.producer.support中的构造器

构造器和说明
ExtensionTransactionalResultAdapter(MessageProducer messageProducer)
ExtensionTransactionalResultAdapter(String transactionId, MessageProducer messageProducer)
ProducerImpl(MessageProducer messageProducer, ExtensionMessageFactory messageFactory)
TransactionalResultAdapter(io.openmessaging.message.Message message, String transactionId, MessageProducer messageProducer)
TransactionProducerImpl(ExtensionProducer delegate, io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener, MessageProducer messageProducer, MessageAccessPoint messageAccessPoint, TxFeedbackConfig txFeedbackConfig)

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

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

限定符和类型	方法和说明
MessageProducer	MessageAccessPoint.createProducer()
MessageProducer	MessageAccessPoint.createProducer(ProducerConfig config)

org.joyqueue.client.internal.producer中MessageProducer的使用

返回MessageProducer的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig)
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ProducerClientManager producerClientManager)
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ProducerClientManager producerClientManager)
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, ProducerClientManager producerClientManager)
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig)
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ProducerClientManager producerClientManager)
static MessageProducer	MessageProducerFactory.create(String address, String app, String token)
static MessageProducer	MessageProducerFactory.create(String address, String app, String token, String region)
static MessageProducer	MessageProducerFactory.create(String address, String app, String token, String region, String namespace)

org.joyqueue.client.internal.producer.support中MessageProducer的使用

实现MessageProducer的org.joyqueue.client.internal.producer.support中的类

限定符和类型	类和说明
class	DefaultMessageProducer DefaultMessageProducer author: gaohaoxiang date: 2018/12/10
class	MessageProducerWrapper MessageProducerWrapper author: gaohaoxiang date: 2018/12/27

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

构造器和说明
MessageProducerWrapper(ClusterManager clusterManager, ProducerClientManager producerClientManager, MessageProducer delegate)

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

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

限定符和类型	方法和说明
MessageProducer	DefaultMessageAccessPoint.createProducer()
MessageProducer	DefaultMessageAccessPoint.createProducer(ProducerConfig config)