You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vi...@apache.org on 2017/01/06 06:30:48 UTC
[2/3] incubator-rocketmq git commit: [ROCKETMQ-17] openmessaging:
refactor ResourceManager ASF JIRA:
https://issues.apache.org/jira/browse/ROCKETMQ-17
[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 <vi...@apache.org>
Authored: Fri Jan 6 14:19:22 2017 +0800
Committer: vintagewang <vi...@apache.org>
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);
}