类 com.taobao.metamorphosis.client.producer.ProducerZooKeeper
的使用

使用 ProducerZooKeeper 的软件包

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

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

声明为 ProducerZooKeeper 的 com.taobao.metamorphosis.client 中的字段

protected ProducerZooKeeper

MetaMessageSessionFactory.producerZooKeeper

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

ProducerZooKeeper

MetaMessageSessionFactory.getProducerZooKeeper() 返回生产者和zk交互管理器

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

参数类型为 ProducerZooKeeper 的 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.producer 中 ProducerZooKeeper 的使用

参数类型为 ProducerZooKeeper 的 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 中 ProducerZooKeeper 的使用

声明为 ProducerZooKeeper 的 com.taobao.metamorphosis.client.producer 中的字段

protected ProducerZooKeeper

SimpleMessageProducer.producerZooKeeper

参数类型为 ProducerZooKeeper 的 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)