com.alibaba.rocketmq.client.consumer.rebalance

类 AllocateMessageQueueAveragelyByCircle

java.lang.Object

com.alibaba.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragelyByCircle

所有已实现的接口:

AllocateMessageQueueStrategy

public class AllocateMessageQueueAveragelyByCircle
extends Object
implements AllocateMessageQueueStrategy

Cycle average Hashing queue algorithm

从以下版本开始:

2014-09-10

作者:

manhong.yqd

构造器概要

构造器

构造器和说明
AllocateMessageQueueAveragelyByCircle()

方法概要

方法

限定符和类型	方法和说明
List<MessageQueue>	allocate(String consumerGroup, String currentCID, List<MessageQueue> mqAll, List<String> cidAll) Allocating by consumer id
String	getName() Algorithm name

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

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

构造器详细资料

AllocateMessageQueueAveragelyByCircle

public AllocateMessageQueueAveragelyByCircle()

方法详细资料

getName

public String getName()

从接口复制的说明: AllocateMessageQueueStrategy

Algorithm name

指定者:

getName 在接口中 AllocateMessageQueueStrategy

返回:

allocate

public List<MessageQueue> allocate(String consumerGroup,
                          String currentCID,
                          List<MessageQueue> mqAll,
                          List<String> cidAll)

从接口复制的说明: AllocateMessageQueueStrategy

Allocating by consumer id

指定者:

allocate 在接口中 AllocateMessageQueueStrategy

参数:

consumerGroup - current consumer group

currentCID - current consumer id

mqAll - message queue set in current topic

cidAll - consumer set in current consumer group

返回: