From b59fef5c00b15fdfdfa9d4be26e5bf6b41c75458 Mon Sep 17 00:00:00 2001
From: admin <2780501319@qq.com>
Date: 星期日, 23 二月 2020 00:16:52 +0800
Subject: [PATCH] 2.0.7相关服务端功能添加
---
utils/src/main/java/com/qcloud/cmq/Subscription.java | 294 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 147 insertions(+), 147 deletions(-)
diff --git a/utils/src/main/java/com/qcloud/cmq/Subscription.java b/utils/src/main/java/com/qcloud/cmq/Subscription.java
index cd9e277..0df3b17 100644
--- a/utils/src/main/java/com/qcloud/cmq/Subscription.java
+++ b/utils/src/main/java/com/qcloud/cmq/Subscription.java
@@ -1,147 +1,147 @@
-package com.qcloud.cmq;
-
-import java.util.TreeMap;
-import java.util.Vector;
-
-import com.qcloud.cmq.Json.JSONArray;
-import com.qcloud.cmq.Json.JSONObject;
-
-/**
- * TODO subscription class.
- *
- * @author York.
- * Created 2016骞�9鏈�27鏃�.
- */
-public class Subscription {
- protected String topicName;
- protected String subscriptionName;
- protected CMQClient client;
- /**
- * TODO construct .
- *
- * @param topicName
- * @param subscriptionName
- * @param client
- */
- Subscription(final String topicName , final String subscriptionName,CMQClient client)
- {
- this.topicName = topicName;
- this.subscriptionName = subscriptionName;
- this.client = client;
- }
- public void ClearFilterTags() throws Exception
- {
- TreeMap<String, String> param = new TreeMap<String, String>();
-
- param.put("topicName",this.topicName);
- param.put("subscriptionName", this.subscriptionName);
- String result = this.client.call("ClearSUbscriptionFIlterTags",param);
-
- JSONObject jsonObj = new JSONObject(result);
- int code = jsonObj.getInt("code");
- if(code != 0)
- throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
-
- }
- /**
- * TODO set subscription attributes.
- *
- * @param meta SubscriptionMeata object
- * @throws Exception
- */
- public void SetSubscriptionAttributes(SubscriptionMeta meta) throws Exception
- {
- TreeMap<String, String> param = new TreeMap<String, String>();
-
- param.put("topicName",this.topicName);
- param.put("subscriptionName", this.subscriptionName);
- if( !meta.NotifyStrategy.equals(""))
- param.put("notifyStrategy",meta.NotifyStrategy);
- if( !meta.NotifyContentFormat.equals(""))
- param.put("notifyContentFormat", meta.NotifyContentFormat);
- if( meta.FilterTag != null )
- {
- int n = 1 ;
- for(String flag : meta.FilterTag)
- {
- param.put("filterTag."+Integer.toString(n), flag);
- ++n;
- }
- }
- if( meta.bindingKey != null )
- {
- int n = 1 ;
- for(String flag : meta.bindingKey)
- {
- param.put("bindingKey."+Integer.toString(n), flag);
- ++n;
- }
- }
-
- String result = this.client.call("SetSubscriptionAttributes", param);
-
- JSONObject jsonObj = new JSONObject(result);
- int code = jsonObj.getInt("code");
- if(code != 0)
- throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
- }
-
- /**
- * TODO get subscription attributes.
- *
- * @return subscription meta object
- * @throws Exception
- */
- public SubscriptionMeta getSubscriptionAttributes() throws Exception
- {
- TreeMap<String, String> param = new TreeMap<String, String>();
-
- param.put("topicName",this.topicName);
- param.put("subscriptionName", this.subscriptionName);
-
- String result = this.client.call("GetSubscriptionAttributes", param);
-
- JSONObject jsonObj = new JSONObject(result);
- int code = jsonObj.getInt("code");
- if(code != 0)
- throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
-
- SubscriptionMeta meta = new SubscriptionMeta();
- meta.FilterTag = new Vector<String>();
- if(jsonObj.has("endpoint"))
- meta.Endpoint = jsonObj.getString("endpoint");
- if(jsonObj.has("notifyStrategy"))
- meta.NotifyStrategy = jsonObj.getString("notifyStrategy");
- if(jsonObj.has("notifyContTentFormat"))
- meta.NotifyContentFormat = jsonObj.getString("notifyContTentFormat");
- if(jsonObj.has("protocol"))
- meta.Protocal = jsonObj.getString("protocol");
- if(jsonObj.has("createTime"))
- meta.CreateTime = jsonObj.getInt("createTime");
- if(jsonObj.has("lastModifyTime"))
- meta.LastModifyTime = jsonObj.getInt("lastModifyTime");
- if(jsonObj.has("msgCount"))
- meta.msgCount = jsonObj.getInt("msgCount");
- if(jsonObj.has("filterTag"))
- {
- JSONArray jsonArray = jsonObj.getJSONArray("filterTag");
- for(int i=0;i<jsonArray.length();i++)
- {
- JSONObject obj = (JSONObject)jsonArray.get(i);
- meta.FilterTag.add(obj.toString());
- }
- }
- if(jsonObj.has("bindingKey"))
- {
- JSONArray jsonArray = jsonObj.getJSONArray("bindingKey");
- for(int i=0;i<jsonArray.length();i++)
- {
- JSONObject obj = (JSONObject)jsonArray.get(i);
- meta.bindingKey.add(obj.toString());
- }
- }
-
- return meta;
- }
-
-}
+package com.qcloud.cmq;
+
+import java.util.TreeMap;
+import java.util.Vector;
+
+import com.qcloud.cmq.Json.JSONArray;
+import com.qcloud.cmq.Json.JSONObject;
+
+/**
+ * TODO subscription class.
+ *
+ * @author York.
+ * Created 2016骞�9鏈�27鏃�.
+ */
+public class Subscription {
+ protected String topicName;
+ protected String subscriptionName;
+ protected CMQClient client;
+ /**
+ * TODO construct .
+ *
+ * @param topicName
+ * @param subscriptionName
+ * @param client
+ */
+ Subscription(final String topicName , final String subscriptionName,CMQClient client)
+ {
+ this.topicName = topicName;
+ this.subscriptionName = subscriptionName;
+ this.client = client;
+ }
+ public void ClearFilterTags() throws Exception
+ {
+ TreeMap<String, String> param = new TreeMap<String, String>();
+
+ param.put("topicName",this.topicName);
+ param.put("subscriptionName", this.subscriptionName);
+ String result = this.client.call("ClearSUbscriptionFIlterTags",param);
+
+ JSONObject jsonObj = new JSONObject(result);
+ int code = jsonObj.getInt("code");
+ if(code != 0)
+ throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
+
+ }
+ /**
+ * TODO set subscription attributes.
+ *
+ * @param meta SubscriptionMeata object
+ * @throws Exception
+ */
+ public void SetSubscriptionAttributes(SubscriptionMeta meta) throws Exception
+ {
+ TreeMap<String, String> param = new TreeMap<String, String>();
+
+ param.put("topicName",this.topicName);
+ param.put("subscriptionName", this.subscriptionName);
+ if( !meta.NotifyStrategy.equals(""))
+ param.put("notifyStrategy",meta.NotifyStrategy);
+ if( !meta.NotifyContentFormat.equals(""))
+ param.put("notifyContentFormat", meta.NotifyContentFormat);
+ if( meta.FilterTag != null )
+ {
+ int n = 1 ;
+ for(String flag : meta.FilterTag)
+ {
+ param.put("filterTag."+Integer.toString(n), flag);
+ ++n;
+ }
+ }
+ if( meta.bindingKey != null )
+ {
+ int n = 1 ;
+ for(String flag : meta.bindingKey)
+ {
+ param.put("bindingKey."+Integer.toString(n), flag);
+ ++n;
+ }
+ }
+
+ String result = this.client.call("SetSubscriptionAttributes", param);
+
+ JSONObject jsonObj = new JSONObject(result);
+ int code = jsonObj.getInt("code");
+ if(code != 0)
+ throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
+ }
+
+ /**
+ * TODO get subscription attributes.
+ *
+ * @return subscription meta object
+ * @throws Exception
+ */
+ public SubscriptionMeta getSubscriptionAttributes() throws Exception
+ {
+ TreeMap<String, String> param = new TreeMap<String, String>();
+
+ param.put("topicName",this.topicName);
+ param.put("subscriptionName", this.subscriptionName);
+
+ String result = this.client.call("GetSubscriptionAttributes", param);
+
+ JSONObject jsonObj = new JSONObject(result);
+ int code = jsonObj.getInt("code");
+ if(code != 0)
+ throw new CMQServerException(code,jsonObj.getString("message"),jsonObj.getString("requestId"));
+
+ SubscriptionMeta meta = new SubscriptionMeta();
+ meta.FilterTag = new Vector<String>();
+ if(jsonObj.has("endpoint"))
+ meta.Endpoint = jsonObj.getString("endpoint");
+ if(jsonObj.has("notifyStrategy"))
+ meta.NotifyStrategy = jsonObj.getString("notifyStrategy");
+ if(jsonObj.has("notifyContTentFormat"))
+ meta.NotifyContentFormat = jsonObj.getString("notifyContTentFormat");
+ if(jsonObj.has("protocol"))
+ meta.Protocal = jsonObj.getString("protocol");
+ if(jsonObj.has("createTime"))
+ meta.CreateTime = jsonObj.getInt("createTime");
+ if(jsonObj.has("lastModifyTime"))
+ meta.LastModifyTime = jsonObj.getInt("lastModifyTime");
+ if(jsonObj.has("msgCount"))
+ meta.msgCount = jsonObj.getInt("msgCount");
+ if(jsonObj.has("filterTag"))
+ {
+ JSONArray jsonArray = jsonObj.getJSONArray("filterTag");
+ for(int i=0;i<jsonArray.length();i++)
+ {
+ JSONObject obj = (JSONObject)jsonArray.get(i);
+ meta.FilterTag.add(obj.toString());
+ }
+ }
+ if(jsonObj.has("bindingKey"))
+ {
+ JSONArray jsonArray = jsonObj.getJSONArray("bindingKey");
+ for(int i=0;i<jsonArray.length();i++)
+ {
+ JSONObject obj = (JSONObject)jsonArray.get(i);
+ meta.bindingKey.add(obj.toString());
+ }
+ }
+
+ return meta;
+ }
+
+}
--
Gitblit v1.8.0