Repository: incubator-rocketmq Updated Branches: refs/heads/spec 58acef9ef -> 2b9e7a5ef
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor MessagingEndPointManager 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/70253cd4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/70253cd4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/70253cd4 Branch: refs/heads/spec Commit: 70253cd44703b006bc0cabf15680851bc9155380 Parents: 58acef9 Author: vintagewang <[email protected]> Authored: Wed Dec 28 16:11:50 2016 +0800 Committer: vintagewang <[email protected]> Committed: Wed Dec 28 16:11:50 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/openmessaging/MessagingEndPoint.java | 6 ++++++ .../org/apache/openmessaging/MessagingEndPointManager.java | 7 +++---- 2 files changed, 9 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/70253cd4/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java index 634f552..d24ec04 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java @@ -24,7 +24,13 @@ public interface MessagingEndPoint { Producer createProducer(); + Producer createProducer(final KeyValue properties); + PushConsumer createPushConsumer(); + PushConsumer createPushConsumer(final KeyValue properties); + PullConsumer createPullConsumer(); + + PullConsumer createPullConsumer(final KeyValue properties); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/70253cd4/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java index 8196658..07796d3 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java @@ -21,20 +21,19 @@ import org.apache.openmessaging.internal.URISpecParser; import java.util.List; import java.util.Map; -import java.util.Properties; public class MessagingEndPointManager { public static MessagingEndPoint getMessagingEndPoint(String url) { - return getMessagingEndPoint(url, new Properties()); + return getMessagingEndPoint(url, null); } - public static MessagingEndPoint getMessagingEndPoint(String url, Properties properties) { + public static MessagingEndPoint getMessagingEndPoint(String url, KeyValue properties) { Map<String, List<String>> driverUrl = URISpecParser.parseURI(url); if (null == driverUrl || driverUrl.size() == 0) { throw new IllegalArgumentException("driver url parsed result.size ==0"); } - return MessagingEndPointFactory.createMessagingEndPoint(driverUrl, properties); + return MessagingEndPointFactory.createMessagingEndPoint(driverUrl, null); } public static KeyValue buildKeyValue() {
