src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h

#pragma once

#include "rocketmq/MQSelector.h"

ROCKETMQ_NAMESPACE_BEGIN

class MessageGroupQueueSelector : public MessageQueueSelector {
public:
  explicit MessageGroupQueueSelector(std::string message_group);

  MQMessageQueue select(const std::vector<MQMessageQueue>& mqs, const MQMessage& msg, void* arg) override;

private:
  std::string message_group_;
};

ROCKETMQ_NAMESPACE_END