接口 com.taobao.metamorphosis.client.producer.MessageProducer
的使用

使用 MessageProducer 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.extension
com.taobao.metamorphosis.client.extension.producer
com.taobao.metamorphosis.client.extension.spring
com.taobao.metamorphosis.client.producer

com.taobao.metamorphosis.client 中 MessageProducer 的使用

返回 MessageProducer 的 com.taobao.metamorphosis.client 中的方法

MessageProducer	MetaMessageSessionFactory.createProducer()
MessageProducer	MessageSessionFactory.createProducer() 创建消息生产者，默认使用轮询分区选择器
MessageProducer	MetaMessageSessionFactory.createProducer(boolean ordered) 已过时。
MessageProducer	MessageSessionFactory.createProducer(boolean ordered) 已过时。
MessageProducer	MetaMessageSessionFactory.createProducer(PartitionSelector partitionSelector)
MessageProducer	MessageSessionFactory.createProducer(PartitionSelector partitionSelector) 创建消息生产者
MessageProducer	MetaMessageSessionFactory.createProducer(PartitionSelector partitionSelector, boolean ordered) 已过时。
MessageProducer	MessageSessionFactory.createProducer(PartitionSelector partitionSelector, boolean ordered) 已过时。

com.taobao.metamorphosis.client.extension 中 MessageProducer 的使用

返回 MessageProducer 的 com.taobao.metamorphosis.client.extension 中的方法

MessageProducer	OrderedMetaMessageSessionFactory.createProducer()
MessageProducer	OrderedMetaMessageSessionFactory.createProducer(boolean ordered)
MessageProducer	OrderedMetaMessageSessionFactory.createProducer(PartitionSelector partitionSelector) 创建消息生产者
MessageProducer	OrderedMetaMessageSessionFactory.createProducer(PartitionSelector partitionSelector, boolean ordered) 创建消息生产者

com.taobao.metamorphosis.client.extension.producer 中 MessageProducer 的使用

com.taobao.metamorphosis.client.extension.producer 中 MessageProducer 的子接口

interface

AsyncMessageProducer 异步发送消息的生产者.

实现 MessageProducer 的 com.taobao.metamorphosis.client.extension.producer 中的类

class	AsyncMetaMessageProducer 异步单向发送消息给服务器的生产者实现.
class	OrderedMessageProducer 有序消息生产者的实现类,需要按照消息内容(例如某个id)散列到固定分区并要求有序的场景中使用.

com.taobao.metamorphosis.client.extension.spring 中 MessageProducer 的使用

返回 MessageProducer 的 com.taobao.metamorphosis.client.extension.spring 中的方法

MessageProducer

MetaqTemplate.getOrCreateProducer(String topic) Returns or create a message producer for topic.

com.taobao.metamorphosis.client.producer 中 MessageProducer 的使用

com.taobao.metamorphosis.client.producer 中 MessageProducer 的子接口

interface

XAMessageProducer 支持XA事务的消息生产者

实现 MessageProducer 的 com.taobao.metamorphosis.client.producer 中的类

class	SimpleMessageProducer 消费生产者实现
class	SimpleXAMessageProducer XA消息生产者的实现类