提交 12979704 编写于 作者: W wlliqipeng

add note

上级 55a05b55
...@@ -55,6 +55,9 @@ public interface MQPushConsumer extends MQConsumer { ...@@ -55,6 +55,9 @@ public interface MQPushConsumer extends MQConsumer {
void subscribe(final String topic, final String subExpression) throws MQClientException; void subscribe(final String topic, final String subExpression) throws MQClientException;
/** /**
* 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 * Subscribe some topic
* *
* @param fullClassName full class name,must extend org.apache.rocketmq.common.filter. MessageFilter * @param fullClassName full class name,must extend org.apache.rocketmq.common.filter. MessageFilter
......
...@@ -720,6 +720,10 @@ public class MQClientInstance { ...@@ -720,6 +720,10 @@ public class MQClientInstance {
return false; return false;
} }
/**
* 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 @Deprecated
private void uploadFilterClassToAllFilterServer(final String consumerGroup, final String fullClassName, private void uploadFilterClassToAllFilterServer(final String consumerGroup, final String fullClassName,
final String topic, final String topic,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册