[ROCKETMQ-17] openmessaging: refactor ResourceManager ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/5f7b9e79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/5f7b9e79 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/5f7b9e79 Branch: refs/heads/spec Commit: 5f7b9e790a47e0609e78c985adc1d592f2256105 Parents: f1003a0 Author: vintagewang <[email protected]> Authored: Fri Jan 6 14:19:22 2017 +0800 Committer: vintagewang <[email protected]> Committed: Fri Jan 6 14:19:22 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/openmessaging/ResourceManager.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/5f7b9e79/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/ResourceManager.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/ResourceManager.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/ResourceManager.java index 7088157..5efa484 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/ResourceManager.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/ResourceManager.java @@ -17,9 +17,15 @@ package org.apache.openmessaging; public interface ResourceManager { - void createNamespace(final String nsname, KeyValue properties); + void createAndUpdateNamespace(final String nsname, KeyValue properties); - void createTopic(final String topicName, KeyValue properties); + void createAndUpdateTopic(final String topicName, KeyValue properties); - void createQueue(final String queueName, KeyValue properties); + void createAndUpdateQueue(final String queueName, KeyValue properties); + + void destroyNamespace(final String nsname); + + void destroyTopic(final String nsname); + + void destroyQueue(final String nsname); }
