提交 4ca1a71c 编写于 作者: W wlliqipeng

no message

上级 12979704
......@@ -55,9 +55,9 @@ public interface MQPushConsumer extends MQConsumer {
void subscribe(final String topic, final String subExpression) throws MQClientException;
/**
* This method will be removed in the version 5.0.0because filterServer was removed,and method <code>subscribe(final String topic, final MessageSelector messageSelector)</code>
* This method will be removed in the version 5.0.0,because filterServer was removed,and method <code>subscribe(final String topic, final MessageSelector messageSelector)</code>
* is recommended.
*
*
* Subscribe some topic
*
* @param fullClassName full class name,must extend org.apache.rocketmq.common.filter. MessageFilter
......
......@@ -721,7 +721,7 @@ public class MQClientInstance {
return false;
}
/**
* This method will be removed in the version 5.0.0because filterServer was removed,and method <code>subscribe(final String topic, final MessageSelector messageSelector)</code>
* This method will be removed in the version 5.0.0,because filterServer was removed,and method <code>subscribe(final String topic, final MessageSelector messageSelector)</code>
* is recommended.
*/
@Deprecated
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册