| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.oozie.service; |
| |
| import org.apache.commons.logging.LogFactory; |
| import org.apache.oozie.command.CommandException; |
| import org.apache.oozie.test.XTestCase; |
| import org.apache.oozie.util.XLog; |
| import org.apache.oozie.util.XLogAuditFilter; |
| import org.apache.oozie.util.XLogAuditStreamer; |
| import org.apache.oozie.util.XLogErrorStreamer; |
| import org.apache.oozie.util.XLogFilter; |
| import org.apache.oozie.util.XLogStreamer; |
| import org.apache.oozie.util.XLogUserFilterParam; |
| |
| import java.io.File; |
| import java.io.FileOutputStream; |
| import java.io.InputStream; |
| import java.io.StringWriter; |
| import java.util.Date; |
| import java.util.Properties; |
| |
| public class TestXLogStreamingService extends XTestCase { |
| |
| final int FIFTEEN_HOURS = 60 * 60 * 1000 * 15; |
| |
| @Override |
| protected void setUp() throws Exception { |
| super.setUp(); |
| } |
| |
| @Override |
| protected void tearDown() throws Exception { |
| super.tearDown(); |
| } |
| |
| private void setupXLog() throws CommandException { |
| XLogFilter.reset(); |
| XLogFilter.defineParameter("USER"); |
| XLogFilter.defineParameter("GROUP"); |
| XLogFilter.defineParameter("TOKEN"); |
| XLogFilter.defineParameter("APP"); |
| XLogFilter.defineParameter("JOB"); |
| XLogFilter.defineParameter("ACTION"); |
| } |
| |
| |
| public void testDisableLogOverWS() throws Exception { |
| Properties props = new Properties(); |
| // Test missing logfile |
| props.setProperty("log4j.appender.oozie.File", ""); |
| File propsFile = new File(getTestCaseConfDir(), "test-disable-log-over-ws-log4j.properties"); |
| FileOutputStream fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| setSystemProperty(XLogService.LOG4J_FILE, propsFile.getName()); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test non-absolute path for logfile |
| props.setProperty("log4j.appender.oozie.File", "oozie.log"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test missing appender class |
| props.setProperty("log4j.appender.oozie.File", "${oozie.log.dir}/oozie.log"); |
| props.setProperty("log4j.appender.oozie", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test appender class not DailyRollingFileAppender or RollingFileAppender |
| props.setProperty("log4j.appender.oozie", "org.blah.blah"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender but missing DatePattern |
| props.setProperty("log4j.appender.oozie", "org.apache.log4j.DailyRollingFileAppender"); |
| props.setProperty("log4j.appender.oozie.DatePattern", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender but DatePattern that doesn't end with 'HH' or 'dd' |
| props.setProperty("log4j.appender.oozie.DatePattern", "'.'yyyy-MM"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender with everything correct (dd) |
| props.setProperty("log4j.appender.oozie.DatePattern", "'.'yyyy-MM-dd"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender with everything correct (HH) |
| props.setProperty("log4j.appender.oozie.DatePattern", "'.'yyyy-MM-dd-HH"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but missing FileNamePattern |
| props.setProperty("log4j.appender.oozie", "org.apache.log4j.rolling.RollingFileAppender"); |
| props.setProperty("log4j.appender.oozie.RollingPolicy.FileNamePattern", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but FileNamePattern with incorrect ending |
| props.setProperty("log4j.appender.oozie.RollingPolicy.FileNamePattern", "${oozie.log.dir}/oozie.log-blah"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but FileNamePattern with incorrect beginning |
| props.setProperty("log4j.appender.oozie.RollingPolicy.FileNamePattern", "${oozie.log.dir}/blah.log-%d{yyyy-MM-dd-HH}"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender with everything correct |
| props.setProperty("log4j.appender.oozie.RollingPolicy.FileNamePattern", "${oozie.log.dir}/oozie.log-%d{yyyy-MM-dd-HH}"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender with everything correct (gz) |
| props.setProperty("log4j.appender.oozie.RollingPolicy.FileNamePattern", "${oozie.log.dir}/oozie.log-%d{yyyy-MM-dd-HH}.gz"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doStreamDisabledCheckWithServices()); |
| } |
| |
| public void testDisableErrorLogOverWS() throws Exception { |
| Properties props = new Properties(); |
| // Test missing logfile |
| props.setProperty("log4j.appender.oozieError.File", ""); |
| File propsFile = new File(getTestCaseConfDir(), "test-disable-log-over-ws-log4j.properties"); |
| FileOutputStream fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| setSystemProperty(XLogService.LOG4J_FILE, propsFile.getName()); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test non-absolute path for logfile |
| props.setProperty("log4j.appender.oozieError.File", "oozie-error.log"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test missing appender class |
| props.setProperty("log4j.appender.oozieError.File", "${oozie.log.dir}/oozie-error.log"); |
| props.setProperty("log4j.appender.oozieError", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test appender class not DailyRollingFileAppender or RollingFileAppender |
| props.setProperty("log4j.appender.oozieError", "org.blah.blah"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender but missing DatePattern |
| props.setProperty("log4j.appender.oozieError", "org.apache.log4j.DailyRollingFileAppender"); |
| props.setProperty("log4j.appender.oozieError.DatePattern", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender but DatePattern that doesn't end with 'HH' or 'dd' |
| props.setProperty("log4j.appender.oozieError.DatePattern", "'.'yyyy-MM"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender with everything correct (dd) |
| props.setProperty("log4j.appender.oozieError.DatePattern", "'.'yyyy-MM-dd"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test DailyRollingFileAppender with everything correct (HH) |
| props.setProperty("log4j.appender.oozieError.DatePattern", "'.'yyyy-MM-dd-HH"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but missing FileNamePattern |
| props.setProperty("log4j.appender.oozieError", "org.apache.log4j.rolling.RollingFileAppender"); |
| props.setProperty("log4j.appender.oozieError.RollingPolicy.FileNamePattern", ""); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but FileNamePattern with incorrect ending |
| props.setProperty("log4j.appender.oozieError.RollingPolicy.FileNamePattern", "${oozie.log.dir}/oozie-error.log-blah"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender but FileNamePattern with incorrect beginning |
| props.setProperty("log4j.appender.oozieError.RollingPolicy.FileNamePattern", |
| "${oozie.log.dir}/blah.log-%d{yyyy-MM-dd-HH}"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertTrue(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender with everything correct |
| props.setProperty("log4j.appender.oozieError.RollingPolicy.FileNamePattern", |
| "${oozie.log.dir}/oozie-error.log-%d{yyyy-MM-dd-HH}"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doerrorStreamDisabledCheckWithServices()); |
| |
| // Test RollingFileAppender with everything correct (gz) |
| props.setProperty("log4j.appender.oozieError.RollingPolicy.FileNamePattern", |
| "${oozie.log.dir}/oozie-error.log-%d{yyyy-MM-dd-HH}.gz"); |
| fos = new FileOutputStream(propsFile); |
| props.store(fos, ""); |
| assertFalse(doerrorStreamDisabledCheckWithServices()); |
| } |
| |
| public void testNoDashInConversionPattern() throws Exception{ |
| setupXLog(); |
| XLogFilter xf = new XLogFilter(new XLogUserFilterParam(null)); |
| xf.setParameter("USER", "oozie"); |
| xf.setLogLevel("DEBUG|INFO"); |
| // Previously, a dash ("-") was always required somewhere in a line in order for that line to pass the filter; this test |
| // checks that this condition is no longer required for log streaming to work |
| File log4jFile = new File(getTestCaseConfDir(), "test-log4j.properties"); |
| ClassLoader cl = Thread.currentThread().getContextClassLoader(); |
| InputStream is = cl.getResourceAsStream("test-no-dash-log4j.properties"); |
| Properties log4jProps = new Properties(); |
| log4jProps.load(is); |
| // prevent conflicts with other tests by changing the log file location |
| log4jProps.setProperty("log4j.appender.oozie.File", getTestCaseDir() + "/oozie.log"); |
| log4jProps.store(new FileOutputStream(log4jFile), ""); |
| setSystemProperty(XLogService.LOG4J_FILE, log4jFile.getName()); |
| try { |
| new Services().init(); |
| assertFalse(doStreamDisabledCheck()); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L1_:317 - SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L2_:317 - SERVER[foo] USER[blah] GROUP[oozie] TOKEN[-]" |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L3_:317 SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] APP[-]" |
| + " JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L4_:317 SERVER[foo] USER[blah] GROUP[oozie] TOKEN[-] APP[-] " |
| + "JOB[-] ACTION[-] Released Lock"); |
| String out = doStreamLog(xf); |
| String outArr[] = out.split("\n"); |
| // Lines 2 and 4 are filtered out because they have the wrong user |
| assertEquals(2, outArr.length); |
| assertTrue(outArr[0].contains("_L1_")); |
| assertFalse(out.contains("_L2_")); |
| assertTrue(outArr[1].contains("_L3_")); |
| assertFalse(out.contains("_L4_")); |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| } |
| |
| public void testErrorLog() throws Exception{ |
| setupXLog(); |
| XLogFilter xf = new XLogFilter(new XLogUserFilterParam(null)); |
| xf.setParameter("USER", "oozie"); |
| xf.setLogLevel("DEBUG|INFO"); |
| // Previously, a dash ("-") was always required somewhere in a line in order for that line to pass the filter; this test |
| // checks that this condition is no longer required for log streaming to work |
| File log4jFile = new File(getTestCaseConfDir(), "test-log4j.properties"); |
| ClassLoader cl = Thread.currentThread().getContextClassLoader(); |
| InputStream is = cl.getResourceAsStream("test-no-dash-log4j.properties"); |
| Properties log4jProps = new Properties(); |
| log4jProps.load(is); |
| // prevent conflicts with other tests by changing the log file location |
| log4jProps.setProperty("log4j.appender.oozie.File", getTestCaseDir() + "/oozie.log"); |
| log4jProps.setProperty("log4j.appender.oozieError.File", getTestCaseDir() + "/oozie-error.log"); |
| |
| log4jProps.store(new FileOutputStream(log4jFile), ""); |
| setSystemProperty(XLogService.LOG4J_FILE, log4jFile.getName()); |
| try { |
| new Services().init(); |
| assertFalse(doStreamDisabledCheck()); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L1_:317 - SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").warn("2009-06-24 02:44:14,505 WARN _L2_:317 - SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Error while writing to file"); |
| LogFactory.getLog("a").info("2009-06-24 02:45:14,505 INFO _L3_:317 - SERVER[foo] USER[blah] GROUP[oozie] TOKEN[-]" |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").error("2009-06-24 02:46:14,505 ERROR _L4_:317 - SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Error while writing to DB"); |
| LogFactory.getLog("a").info("2009-06-24 02:47:14,505 INFO _L5_:317 SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| LogFactory.getLog("a").fatal("2009-06-24 02:48:14,505 FATAL _L6_:317 SERVER[foo] USER[blah] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] Released Lock"); |
| String out = doStreamLog(xf); |
| String outArr[] = out.split("\n"); |
| // Lines 2 and 4 are filtered out because they have the wrong user |
| assertEquals(2, outArr.length); |
| assertTrue(outArr[0].contains("_L1_")); |
| assertFalse(out.contains("_L3_")); |
| assertTrue(outArr[1].contains("_L5_")); |
| assertFalse(out.contains("_L4_")); |
| XLogFilter.reset(); |
| XLogFilter.defineParameter("USER"); |
| XLogFilter.defineParameter("GROUP"); |
| XLogFilter.defineParameter("TOKEN"); |
| XLogFilter.defineParameter("APP"); |
| XLogFilter.defineParameter("JOB"); |
| XLogFilter.defineParameter("ACTION"); |
| xf = new XLogFilter(new XLogUserFilterParam(null)); |
| |
| xf.setParameter("USER", "oozie"); |
| |
| String errorOut = doStreamErrorLog(xf); |
| String errorOutArr[] = errorOut.split("\n"); |
| // Lines 2 and 4 are filtered out because they have the wrong user |
| assertEquals(2, errorOutArr.length); |
| assertTrue(errorOutArr[0].contains("_L2_")); |
| assertTrue(errorOutArr[1].contains("_L4_")); |
| assertFalse(errorOut.contains("_L6_")); |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| } |
| |
| public void testAuditLog() throws Exception { |
| setupXLog(); |
| XLogFilter xf = new XLogAuditFilter(new XLogUserFilterParam(null)); |
| xf.setParameter("USER", "oozie"); |
| xf.setLogLevel("DEBUG|INFO"); |
| File log4jFile = new File(getTestCaseConfDir(), "test-log4j.properties"); |
| ClassLoader cl = Thread.currentThread().getContextClassLoader(); |
| InputStream is = cl.getResourceAsStream("test-no-dash-log4j.properties"); |
| Properties log4jProps = new Properties(); |
| log4jProps.load(is); |
| // prevent conflicts with other tests by changing the log file location |
| log4jProps.setProperty("log4j.appender.oozie.File", getTestCaseDir() + "/oozie.log"); |
| log4jProps.setProperty("log4j.appender.oozieaudit.File", getTestCaseDir() + "/oozie-audit.log"); |
| |
| log4jProps.store(new FileOutputStream(log4jFile), ""); |
| setSystemProperty(XLogService.LOG4J_FILE, log4jFile.getName()); |
| try { |
| new Services().init(); |
| XLog auditLog = XLog.getLog("oozieaudit"); |
| xf.setParameter(DagXLogInfoService.JOB, "0000000-150322000230582-oozie-puru-C"); |
| |
| |
| auditLog.info("2015-03-22 00:04:35,494 INFO oozieaudit:520 - IP [127.0.0.1], USER [purushah], GROUP [null], " |
| + "APP [-], JOBID [0000000-150322000230582-oozie-puru-C], OPERATION [start], " |
| + "PARAMETER [null], STATUS [SUCCESS], HTTPCODE [200], ERRORCODE [null], ERRORMESSAGE [L1]"); |
| auditLog.info("2015-03-22 00:05:13,823 INFO oozieaudit:520 - IP [127.0.0.1], USER [purushah], GROUP [null], " |
| + "APP [-], JOBID [0000000-150322000230582-oozie-puru-C], OPERATION [suspend], " |
| + "PARAMETER [0000000-150322000230582-oozie-puru-C], STATUS [SUCCESS], HTTPCODE [200], ERRORCODE [null], " |
| + "ERRORMESSAGE [L2]"); |
| auditLog.info("2015-03-22 00:05:13,823 INFO oozieaudit:520 - IP [127.0.0.1], USER [purushah], GROUP [null], " |
| + "APP [-], JOBID [0000001-150322000230582-oozie-puru-C], OPERATION [suspend], " |
| + "PARAMETER [0000001-150322000230582-oozie-puru-C], STATUS [SUCCESS], HTTPCODE [200], ERRORCODE [null], " |
| + "ERRORMESSAGE [L3]"); |
| |
| |
| String out = doStreamAuditLog(xf); |
| String outArr[] = out.split("\n"); |
| // Lines 2 and 4 are filtered out because they have the wrong user |
| assertEquals(2, outArr.length); |
| assertTrue(outArr[0].contains("L1")); |
| assertTrue(out.contains("L2")); |
| assertFalse(out.contains("L3")); |
| |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| } |
| |
| public void testTuncateLog() throws Exception { |
| File log4jFile = new File(getTestCaseConfDir(), "test-log4j.properties"); |
| ClassLoader cl = Thread.currentThread().getContextClassLoader(); |
| InputStream is = cl.getResourceAsStream("test-no-dash-log4j.properties"); |
| Properties log4jProps = new Properties(); |
| log4jProps.load(is); |
| log4jProps.setProperty("log4j.appender.oozie.File", getTestCaseDir() + "/oozie.log"); |
| log4jProps.store(new FileOutputStream(log4jFile), ""); |
| setSystemProperty(XLogService.LOG4J_FILE, log4jFile.getName()); |
| |
| new Services().init(); |
| ConfigurationService.set(XLogFilter.MAX_SCAN_DURATION, "10"); |
| Date startDate = new Date(); |
| Date endDate = new Date(startDate.getTime() + FIFTEEN_HOURS); |
| String log = doStreamLog(new XLogFilter(), startDate, endDate); |
| assertTrue(log.contains("Truncated logs to max log scan duration")); |
| log = doStreamErrorLog(new XLogFilter(), startDate, endDate); |
| assertFalse(log.contains("Truncated logs to max log scan duration")); |
| log = doStreamAuditLog(new XLogFilter(), startDate, endDate); |
| assertFalse(log.contains("Truncated logs to max log scan duration")); |
| } |
| |
| public void testEscapingHtmlCharacters() throws Exception{ |
| setupXLog(); |
| XLogFilter xf = new XLogFilter(new XLogUserFilterParam(null)); |
| xf.setParameter("USER", "oozie"); |
| xf.setLogLevel("DEBUG|INFO"); |
| File log4jFile = new File(getTestCaseConfDir(), "test-log4j.properties"); |
| ClassLoader cl = Thread.currentThread().getContextClassLoader(); |
| InputStream is = cl.getResourceAsStream("test-no-dash-log4j.properties"); |
| Properties log4jProps = new Properties(); |
| log4jProps.load(is); |
| // prevent conflicts with other tests by changing the log file location |
| log4jProps.setProperty("log4j.appender.oozie.File", getTestCaseDir() + "/oozie.log"); |
| log4jProps.store(new FileOutputStream(log4jFile), ""); |
| setSystemProperty(XLogService.LOG4J_FILE, log4jFile.getName()); |
| try { |
| new Services().init(); |
| assertFalse(doStreamDisabledCheck()); |
| LogFactory.getLog("a").info("2009-06-24 02:43:14,505 INFO _L1_:317 - SERVER[foo] USER[oozie] GROUP[oozie] TOKEN[-] " |
| + "APP[-] JOB[-] ACTION[-] <script>function({Some malicious JS code});</script>"); |
| String out = doStreamLog(xf); |
| assertFalse(out.contains("<script>")); |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| } |
| |
| private boolean doStreamDisabledCheckWithServices() throws Exception { |
| boolean result = false; |
| try { |
| new Services().init(); |
| result = doStreamDisabledCheck(); |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| return result; |
| } |
| |
| private boolean doStreamDisabledCheck() throws Exception { |
| XLogFilter xf = new XLogFilter(new XLogUserFilterParam(null)); |
| |
| return doStreamLog(xf).equals("Log streaming disabled!!"); |
| } |
| |
| private String doStreamLog(XLogFilter xf) throws Exception { |
| return doStreamLog(new XLogStreamer(xf), null, null); |
| } |
| |
| private String doStreamErrorLog(XLogFilter xf) throws Exception { |
| return doStreamLog(new XLogErrorStreamer(xf, null), null, null); |
| } |
| |
| private String doStreamAuditLog(XLogFilter xf) throws Exception { |
| return doStreamLog(new XLogAuditStreamer(xf, null), null, null); |
| } |
| |
| private String doStreamLog(XLogStreamer logStreamer, Date startDate, Date endDate) throws Exception { |
| StringWriter w = new StringWriter(); |
| Services.get().get(XLogStreamingService.class) |
| .streamLog(logStreamer, startDate, endDate, w); |
| return w.toString(); |
| } |
| |
| private String doStreamLog(XLogFilter xf, Date startDate, Date endDate) throws Exception { |
| return doStreamLog(new XLogStreamer(xf, null), startDate, endDate); |
| } |
| |
| private String doStreamErrorLog(XLogFilter xf, Date startDate, Date endDate) throws Exception { |
| return doStreamLog(new XLogErrorStreamer(xf, null), null, null); |
| } |
| |
| private String doStreamAuditLog(XLogFilter xf, Date startDate, Date endDate) throws Exception { |
| return doStreamLog(new XLogAuditStreamer(xf, null), null, null); |
| } |
| |
| private boolean doErrorStreamDisabledCheck() throws Exception { |
| XLogFilter xf = new XLogFilter(new XLogUserFilterParam(null)); |
| return doStreamErrorLog(xf).equals("Error Log is disabled!!"); |
| } |
| |
| private boolean doerrorStreamDisabledCheckWithServices() throws Exception { |
| boolean result = false; |
| try { |
| new Services().init(); |
| result = doErrorStreamDisabledCheck(); |
| } |
| finally { |
| Services.get().destroy(); |
| } |
| return result; |
| } |
| } |
