#include "FilterExpression.h" | |
ROCKETMQ_NAMESPACE_BEGIN | |
bool FilterExpression::accept(const MQMessageExt& message) const { | |
switch (type_) { | |
case ExpressionType::TAG: { | |
if (WILD_CARD_TAG == content_) { | |
return true; | |
} else { | |
return message.getTags() == content_; | |
} | |
} | |
case ExpressionType::SQL92: { | |
// Server should have strictly filtered. | |
return true; | |
} | |
} | |
return true; | |
} | |
const char* FilterExpression::WILD_CARD_TAG = "*"; | |
ROCKETMQ_NAMESPACE_END |