com.taobao.metamorphosis.client
类 XAMetaMessageSessionFactory

java.lang.Object
  com.taobao.metamorphosis.client.MetaMessageSessionFactory
      com.taobao.metamorphosis.client.XAMetaMessageSessionFactory

所有已实现的接口：

MessageSessionFactory, Shutdownable, XAMessageSessionFactory

public class XAMetaMessageSessionFactory
extends MetaMessageSessionFactory
implements XAMessageSessionFactory

支持事务的XA消息工厂

作者：

boyan(boyan@taobao.com)

字段摘要

从类 com.taobao.metamorphosis.client.MetaMessageSessionFactory 继承的字段

MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY

构造方法摘要

XAMetaMessageSessionFactory(MetaClientConfig metaClientConfig)

方法摘要

XAMessageProducer	createXAProducer() 创建XA消息生产者，默认使用轮询分区选择器
XAMessageProducer	createXAProducer(PartitionSelector partitionSelector) 创建XA消息生产者

从类 com.taobao.metamorphosis.client.MetaMessageSessionFactory 继承的方法

addChild, checkConsumerConfig, createConsumer, createConsumer, createConsumer, createLoadBalanceStrategy, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getChildren, getConsumerZooKeeper, getMetaClientConfig, getPartitionsForTopic, getProducerZooKeeper, getRecoverStorageManager, getRemotingClient, getStats, getStats, getStats, getStats, getSubscribeInfoManager, initConsumerZooKeeper, removeChild, shutdown

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口 com.taobao.metamorphosis.client.MessageSessionFactory 继承的方法

createConsumer, createConsumer, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getPartitionsForTopic, getStats, getStats, getStats, getStats, shutdown

构造方法详细信息

XAMetaMessageSessionFactory

public XAMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
                            throws MetaClientException

抛出：

MetaClientException

方法详细信息

createXAProducer

public XAMessageProducer createXAProducer(PartitionSelector partitionSelector)

从接口 XAMessageSessionFactory 复制的描述

创建XA消息生产者

指定者：

接口 XAMessageSessionFactory 中的 createXAProducer

参数：

partitionSelector - 分区选择器

返回：

createXAProducer

public XAMessageProducer createXAProducer()

从接口 XAMessageSessionFactory 复制的描述

创建XA消息生产者，默认使用轮询分区选择器

指定者：

接口 XAMessageSessionFactory 中的 createXAProducer

返回：