import org.apache.http.protocol.HTTP;\r
import org.apache.logging.log4j.LogManager;\r
import org.apache.logging.log4j.Logger;\r
+import org.apache.logging.log4j.Marker;\r
+import org.apache.logging.log4j.MarkerManager;\r
import org.w3c.dom.Document;\r
import org.w3c.dom.NamedNodeMap;\r
import org.w3c.dom.Node;\r
}\r
\r
private static final Logger logger = LogManager.getLogger();\r
+ private Marker subtitleMarker = MarkerManager.getMarker("MISSING-SUBTITLE");\r
private static final int CONNECTION_TIMEOUT = 5000;\r
private static final int SOCKET_TIMEOUT = 5000;\r
public static final String GETMEDIAUSAGEBYUTRANGE = "/getMediaUsageByUTRange";\r
\r
TreeMap<String, MMMedia> sortedUsages = new TreeMap<>();\r
for (MMMedia m : result.values()) {\r
- //a TreeMap lehetove teszi: nincs duplikatum + a korabbi musorok elore kerulnek\r
+ // a TreeMap lehetove teszi: nincs duplikatum + a korabbi musorok elore kerulnek\r
sortedUsages.put(m.getUsage() + "." + m.getName(), m);\r
}\r
\r
return Paths.get(configDir, viewName);\r
}\r
\r
- public void init(String primaryEndPoint, String primaryUserName, String primaryPassword, String secondaryEndPoint, String secondaryUserName,\r
- String secondaryPassword, int rangeForwardHours) throws Exception {\r
+ public void init(String primaryEndPoint, String primaryUserName, String primaryPassword, String secondaryEndPoint,\r
+ String secondaryUserName, String secondaryPassword, int rangeForwardHours) throws Exception {\r
this.primaryEndPoint = primaryEndPoint;\r
this.primaryUserName = primaryUserName;\r
this.primaryPassword = primaryPassword;\r
private void putEarliest(Map<String, MMMedia> result, String mediaName, String usageTime) {\r
if (result.containsKey(mediaName)) {\r
MMMedia m = result.get(mediaName);\r
- //az aktualis a korabbi idopont\r
+ // az aktualis a korabbi idopont\r
if (usageTime.compareTo(m.getUsage()) < 0)\r
result.put(mediaName, new MMMedia(mediaName, usageTime));\r
} else\r
HttpConnectionParams.setConnectionTimeout(httpParameters, CONNECTION_TIMEOUT);\r
HttpConnectionParams.setSoTimeout(httpParameters, SOCKET_TIMEOUT);\r
DefaultHttpClient httpclient = new DefaultHttpClient(httpParameters);\r
- //http://10.170.100.61:18083\r
+ // http://10.170.100.61:18083\r
\r
String result = null;\r
DataInputStream is = null;\r
try {\r
URL url = new URL(endPoint);\r
- httpclient.getCredentialsProvider()\r
- .setCredentials(new AuthScope(url.getHost(), url.getPort(), null, "Digest"), new UsernamePasswordCredentials(user, pwd));\r
+ httpclient.getCredentialsProvider().setCredentials(\r
+ new AuthScope(url.getHost(), url.getPort(), null, "Digest"),\r
+ new UsernamePasswordCredentials(user, pwd));\r
\r
HttpPost httppost = new HttpPost(url.toURI());\r
httppost.setHeader("soapaction", action);\r
- //Content-Type application/soap+xml; charset=utf-8; action="/getMediaUsageByUTRange"\r
+ // Content-Type application/soap+xml; charset=utf-8;\r
+ // action="/getMediaUsageByUTRange"\r
httppost.setHeader("Content-Type", "text/xml; charset=utf-8");\r
HttpEntity entity = new StringEntity(soap.toString(), HTTP.UTF_8);\r
httppost.setEntity(entity);\r
logger.info("Executing call {}", action);\r
HttpResponse response = httpclient.execute(httppost);// calling server\r
- HttpEntity r_entity = response.getEntity(); //get response\r
- // Header[] headers = response.getAllHeaders();\r
- // for (Header h : headers) {\r
- // logger.info("Reponse Header", h.getName() + ": " + h.getValue());\r
- // }\r
+ HttpEntity r_entity = response.getEntity(); // get response\r
+ // Header[] headers = response.getAllHeaders();\r
+ // for (Header h : headers) {\r
+ // logger.info("Reponse Header", h.getName() + ": " + h.getValue());\r
+ // }\r
if (r_entity != null) {\r
byte[] bytes = new byte[(int) r_entity.getContentLength()];\r
if (r_entity.isStreaming()) {\r
Node mediaNode = mediaNodes.item(i);\r
String mediaName = getAttribute(mediaNode, "mediaName");\r
if (StringUtils.isBlank(mediaName)) {\r
- logger.info("Missing mediaName");\r
continue;\r
}\r
\r
+ String usageType = getAttribute(mediaNode, "UsageType");\r
+ if (!"PrimaryVideo".equals(usageType) && !"Live".equals(usageType))\r
+ logger.info(subtitleMarker, "queryOtherMedias: {}, {}", usageType, mediaName);\r
+\r
if (poolContent.contains(mediaName))\r
continue;\r
\r
Node mediaNode = mediaNodes.item(i);\r
String mediaName = getAttribute(mediaNode, "mediaName");\r
String mediaType = getAttribute(mediaNode, "mediaType");\r
- if (StringUtils.isBlank(mediaName)) {\r
- logger.info("Missing mediaName");\r
+ if (StringUtils.isBlank(mediaName))\r
continue;\r
- }\r
\r
- if (!StringUtils.equals("Video", mediaType)) {\r
+ if (!StringUtils.equals("Subtitle", mediaType))\r
+ logger.info(subtitleMarker, "querySortableMedias: {}", mediaName);\r
+\r
+ if (!StringUtils.equals("Video", mediaType))\r
continue;\r
- }\r
\r
if (poolContent.contains(mediaName))\r
continue;\r