提交 f5c9aaa6 编写于 作者: D duhenglucky 提交者: von gosling

Deprecate sendMessageBack for change it's visibilty in the future

上级 264f2705
...@@ -186,7 +186,6 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume ...@@ -186,7 +186,6 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume
return brokerSuspendMaxTimeMillis; return brokerSuspendMaxTimeMillis;
} }
/** /**
* This method will be removed in a certain version after April 5, 2020, so please do not use this method. * This method will be removed in a certain version after April 5, 2020, so please do not use this method.
*/ */
...@@ -243,12 +242,22 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume ...@@ -243,12 +242,22 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume
this.registerTopics = registerTopics; this.registerTopics = registerTopics;
} }
/**
* This method will be removed or it's visibility will be changed in a certain version after April 5, 2020, so
* please do not use this method.
*/
@Deprecated
@Override @Override
public void sendMessageBack(MessageExt msg, int delayLevel) public void sendMessageBack(MessageExt msg, int delayLevel)
throws RemotingException, MQBrokerException, InterruptedException, MQClientException { throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
this.defaultMQPullConsumerImpl.sendMessageBack(msg, delayLevel, null); this.defaultMQPullConsumerImpl.sendMessageBack(msg, delayLevel, null);
} }
/**
* This method will be removed or it's visibility will be changed in a certain version after April 5, 2020, so
* please do not use this method.
*/
@Deprecated
@Override @Override
public void sendMessageBack(MessageExt msg, int delayLevel, String brokerName) public void sendMessageBack(MessageExt msg, int delayLevel, String brokerName)
throws RemotingException, MQBrokerException, InterruptedException, MQClientException { throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
...@@ -385,7 +394,6 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume ...@@ -385,7 +394,6 @@ public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsume
return offsetStore; return offsetStore;
} }
/** /**
* This method will be removed in a certain version after April 5, 2020, so please do not use this method. * This method will be removed in a certain version after April 5, 2020, so please do not use this method.
*/ */
......
...@@ -579,6 +579,9 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume ...@@ -579,6 +579,9 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume
/** /**
* Send message back to broker which will be re-delivered in future. * Send message back to broker which will be re-delivered in future.
* *
* This method will be removed or it's visibility will be changed in a certain version after April 5, 2020, so
* please do not use this method.
*
* @param msg Message to send back. * @param msg Message to send back.
* @param delayLevel delay level. * @param delayLevel delay level.
* @throws RemotingException if there is any network-tier error. * @throws RemotingException if there is any network-tier error.
...@@ -586,6 +589,7 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume ...@@ -586,6 +589,7 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume
* @throws InterruptedException if the thread is interrupted. * @throws InterruptedException if the thread is interrupted.
* @throws MQClientException if there is any client error. * @throws MQClientException if there is any client error.
*/ */
@Deprecated
@Override @Override
public void sendMessageBack(MessageExt msg, int delayLevel) public void sendMessageBack(MessageExt msg, int delayLevel)
throws RemotingException, MQBrokerException, InterruptedException, MQClientException { throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
...@@ -596,6 +600,9 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume ...@@ -596,6 +600,9 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume
* Send message back to the broker whose name is <code>brokerName</code> and the message will be re-delivered in * Send message back to the broker whose name is <code>brokerName</code> and the message will be re-delivered in
* future. * future.
* *
* This method will be removed or it's visibility will be changed in a certain version after April 5, 2020, so
* please do not use this method.
*
* @param msg Message to send back. * @param msg Message to send back.
* @param delayLevel delay level. * @param delayLevel delay level.
* @param brokerName broker name. * @param brokerName broker name.
...@@ -604,6 +611,7 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume ...@@ -604,6 +611,7 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume
* @throws InterruptedException if the thread is interrupted. * @throws InterruptedException if the thread is interrupted.
* @throws MQClientException if there is any client error. * @throws MQClientException if there is any client error.
*/ */
@Deprecated
@Override @Override
public void sendMessageBack(MessageExt msg, int delayLevel, String brokerName) public void sendMessageBack(MessageExt msg, int delayLevel, String brokerName)
throws RemotingException, MQBrokerException, InterruptedException, MQClientException { throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册