Package com.alibaba.cloud.stream.binder.rocketmq.provisioning.selector

Class PartitionMessageQueueSelector

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.provisioning.selector.PartitionMessageQueueSelector

All Implemented Interfaces:

org.apache.rocketmq.client.producer.MessageQueueSelector

public class PartitionMessageQueueSelector
extends Object
implements org.apache.rocketmq.client.producer.MessageQueueSelector

Author:

wangxing

Constructor Summary

Constructors

Constructor	Description
PartitionMessageQueueSelector()

Method Summary

Modifier and Type	Method	Description
org.apache.rocketmq.common.message.MessageQueue	select(List<org.apache.rocketmq.common.message.MessageQueue> mqs, org.apache.rocketmq.common.message.Message msg, Object arg)

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionMessageQueueSelector

public PartitionMessageQueueSelector()

Method Details

select

public org.apache.rocketmq.common.message.MessageQueue select(List<org.apache.rocketmq.common.message.MessageQueue> mqs,
 org.apache.rocketmq.common.message.Message msg,
 Object arg)

Specified by:

select in interface org.apache.rocketmq.client.producer.MessageQueueSelector