You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/11/14 07:36:47 UTC
[incubator-eventmesh] branch protocol-amqp updated: implementation of naming service
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch protocol-amqp
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/protocol-amqp by this push:
new 979816cb implementation of naming service
new 93289862 Merge pull request #2212 from jackyluo-learning/protocol-amqp-shadow6
979816cb is described below
commit 979816cbac380427596bbe6ae98a05ad2cbbbb1a
Author: jackyluo <15...@qq.com>
AuthorDate: Mon Nov 14 15:25:12 2022 +0800
implementation of naming service
---
.../core/protocol/amqp/naming/ExchangeName.java | 19 +++++++++++++++++++
.../runtime/core/protocol/amqp/naming/QueueName.java | 19 +++++++++++++++++++
2 files changed, 38 insertions(+)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/ExchangeName.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/ExchangeName.java
new file mode 100644
index 00000000..5c27df28
--- /dev/null
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/ExchangeName.java
@@ -0,0 +1,19 @@
+package org.apache.eventmesh.runtime.core.protocol.amqp.naming;
+
+public class ExchangeName {
+
+ private final String ExchangeName;
+ private final String virtualHostName;
+
+ public ExchangeName(String exchangeName, String virtualHostName) {
+ this.ExchangeName = exchangeName;
+ this.virtualHostName = virtualHostName;
+ }
+
+ public static ExchangeName get(String virtualHost, String exchangeName) {
+
+ return new ExchangeName(virtualHost, exchangeName);
+ }
+
+
+}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/QueueName.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/QueueName.java
new file mode 100644
index 00000000..1f7a5ea3
--- /dev/null
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/amqp/naming/QueueName.java
@@ -0,0 +1,19 @@
+package org.apache.eventmesh.runtime.core.protocol.amqp.naming;
+
+public class QueueName {
+
+ private final String queueName;
+ private final String virtualHostName;
+
+ public QueueName(String queueName, String virtualHostName) {
+ this.queueName = queueName;
+ this.virtualHostName = virtualHostName;
+ }
+
+ public static QueueName get(String virtualHost, String queueName) {
+
+ return new QueueName(virtualHost, queueName);
+ }
+
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org