This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch OpenMessaging in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git
commit 6992b4ee81b309ec4945caa032702133d09d000d Author: duhenglucky <[email protected]> AuthorDate: Tue Sep 3 18:18:29 2019 +0800 Add create pull consumer unsupport exception --- .../main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/ons-core/ons-client/src/main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java b/ons-core/ons-client/src/main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java index 05cb230..3a0a96b 100644 --- a/ons-core/ons-client/src/main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java +++ b/ons-core/ons-client/src/main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java @@ -21,6 +21,7 @@ import io.openmessaging.Constants; import io.openmessaging.Consumer; import io.openmessaging.Message; import io.openmessaging.MessagingAccessPoint; +import io.openmessaging.OMSResponseStatus; import io.openmessaging.Producer; import io.openmessaging.PullConsumer; import io.openmessaging.batch.BatchConsumer; @@ -59,7 +60,7 @@ public class MessagingAccessPointImpl implements MessagingAccessPoint { } @Override public PullConsumer createPullConsumer(Properties properties) { - return null; + throw OMSResponseStatus.generateException(OMSResponseStatus.STATUS_1101); } @Override
