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

使用 RemotingClientWrapper 的软件包

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

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

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

protected RemotingClientWrapper

MetaMessageSessionFactory.remotingClient

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

RemotingClientWrapper

MetaMessageSessionFactory.getRemotingClient() 返回通讯客户端

参数类型为 RemotingClientWrapper 的 com.taobao.metamorphosis.client 中的方法

protected ConsumerZooKeeper

MetaMessageSessionFactory.initConsumerZooKeeper(RemotingClientWrapper remotingClientWrapper, org.I0Itec.zkclient.ZkClient zkClient2, ZkUtils.ZKConfig config)

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

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

ConsumerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig)

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 中 RemotingClientWrapper 的使用

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

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

protected RemotingClientWrapper

SimpleMessageProducer.remotingClient

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

ProducerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, MetaClientConfig metaClientConfig)

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 中 RemotingClientWrapper 的使用

参数类型为 RemotingClientWrapper 的 com.taobao.metamorphosis.metaslave 中的方法

protected ConsumerZooKeeper

SlaveMetaMessageSessionFactory.initConsumerZooKeeper(RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig)

参数类型为 RemotingClientWrapper 的 com.taobao.metamorphosis.metaslave 中的构造方法

SlaveConsumerZooKeeper(MetaZookeeper metaZookeeper, RemotingClientWrapper remotingClient, org.I0Itec.zkclient.ZkClient zkClient, ZkUtils.ZKConfig zkConfig, int brokerId)

SlaveOffsetStorage(MetaMorphosisBroker broker, com.taobao.metamorphosis.metaslave.SlaveZooKeeper slaveZooKeeper, RemotingClientWrapper remotingClient)