类 com.taobao.metamorphosis.client.MetaMessageSessionFactory
的使用

使用 MetaMessageSessionFactory 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.extension
com.taobao.metamorphosis.client.extension.consumer
com.taobao.metamorphosis.client.extension.producer
com.taobao.metamorphosis.client.producer
com.taobao.metamorphosis.metaslave

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

com.taobao.metamorphosis.client 中 MetaMessageSessionFactory 的子类

class

XAMetaMessageSessionFactory 支持事务的XA消息工厂

com.taobao.metamorphosis.client.consumer 中 MetaMessageSessionFactory 的使用

返回 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.consumer 中的方法

MetaMessageSessionFactory

SimpleMessageConsumer.getParent()

参数类型为 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.consumer 中的构造方法

SimpleMessageConsumer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, ConsumerConfig consumerConfig, ConsumerZooKeeper consumerZooKeeper, ProducerZooKeeper producerZooKeeper, SubscribeInfoManager subscribeInfoManager, RecoverManager recoverManager, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)

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

com.taobao.metamorphosis.client.extension 中 MetaMessageSessionFactory 的子类

class	AsyncMetaMessageSessionFactory 用于创建异步单向发送消息的会话工厂.
class	ExtMetaMessageSessionFactory 一个扩展的Meta会话工厂,提供一些扩展功能.
class	MetaBroadcastMessageSessionFactory 广播消息会话工厂,使用这个创建的Consumer在同一分组内的每台机器都能收到同一条消息, 推荐一个应用只使用一个MessageSessionFactory
class	OrderedMetaMessageSessionFactory 消息会话工厂，meta客户端的主接口,推荐一个应用只使用一个.

com.taobao.metamorphosis.client.extension.consumer 中 MetaMessageSessionFactory 的使用

参数类型为 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.extension.consumer 中的方法

RecoverManager	ConsumerRecoverType.getNotifyRecoverManager(MetaMessageSessionFactory factory, String notifyRecoverTopic)
RecoverManager	ConsumerRecoverType.getRecoverManager(MetaMessageSessionFactory factory)

参数类型为 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.extension.consumer 中的构造方法

RecoverNotifyManager(MetaMessageSessionFactory factory, String recoverNotifyTopic, RecoverManager next)

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

参数类型为 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.extension.producer 中的构造方法

AsyncMetaMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId, int slidingWindowSize0, AsyncMessageProducer.IgnoreMessageProcessor processor)

OrderedMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId, MessageRecoverManager localMessageStorageManager)

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

返回 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.producer 中的方法

MetaMessageSessionFactory

SimpleMessageProducer.getParent()

参数类型为 MetaMessageSessionFactory 的 com.taobao.metamorphosis.client.producer 中的构造方法

SimpleMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId)

SimpleXAMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId)

com.taobao.metamorphosis.metaslave 中 MetaMessageSessionFactory 的使用

com.taobao.metamorphosis.metaslave 中 MetaMessageSessionFactory 的子类

class

SlaveMetaMessageSessionFactory