浏览代码

channel properties in <channel> tag in request xml

tags/channel_throttling_1
ymlam 1年前
父节点
当前提交
18204d017f
共有 2 个文件被更改,包括 16 次插入6 次删除
  1. +2
    -0
      src/main/java/altk/comm/engine/Broadcast.java
  2. +14
    -6
      src/main/java/altk/comm/engine/XMLSAXBroadcast.java

+ 2
- 0
src/main/java/altk/comm/engine/Broadcast.java 查看文件

@@ -48,6 +48,7 @@ public abstract class Broadcast
private static final long SLEEP_BETWEEN_JOBS_DEFAULT = 0;
static final String DAILY_STOP_KEY = "daily_stop";
static final String DAILY_START_KEY = "daily_start";
static final String CHANNEL_KEY = "channel";

static final String CSV_LOGGER = "csv";
@@ -77,6 +78,7 @@ public abstract class Broadcast
private Postback postback;
protected String daily_start = "";
protected String daily_stop = "";
protected JSONObject channel_json;
/**
* Sleep time in milliseconds between consecutive job processing (actualliy batch)


+ 14
- 6
src/main/java/altk/comm/engine/XMLSAXBroadcast.java 查看文件

@@ -2,6 +2,7 @@ package altk.comm.engine;

import java.io.IOException;
import java.io.InputStream;
import java.text.ParseException;
import java.util.HashMap;
import java.util.Map;
import java.util.zip.ZipInputStream;
@@ -11,6 +12,9 @@ import javax.xml.parsers.ParserConfigurationException;
import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;

import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;

import org.xml.sax.Attributes;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
@@ -104,13 +108,17 @@ public abstract class XMLSAXBroadcast extends Broadcast
{
postbackURL = getTrimmedText();
}
else if (qName.equals(DAILY_STOP_KEY))
{
daily_stop = getTrimmedText();
}
else if (qName.equals(DAILY_START_KEY))
else if (qName.equals(CHANNEL_KEY))
{
daily_start = getTrimmedText();
JSONParser jsonParser = new JSONParser();
String channel_str = getTrimmedText();
try {
channel_json = (JSONObject) jsonParser.parse(channel_str);
} catch (org.json.simple.parser.ParseException e) {
throw new RuntimeException(String.format("<%s> is not json string: %s", CHANNEL_KEY, channel_str));
}
daily_stop = (String)channel_json.get(DAILY_STOP_KEY);
daily_stop = (String)channel_json.get(DAILY_START_KEY);
}
else if (inRecipientProp)
{


正在加载...
取消
保存