You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/11/22 09:22:32 UTC
[rocketmq-ons] 30/36: Add create pull consumer unsupport exception
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 <du...@gmail.com>
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