Omaha #3152 removed monitorsrv
jmx plugin that is currently not used and required dependency maintenance Former-commit-id:083b68d7b4[formerly2de644c9e3] [formerly87aa26bf5a] [formerly083b68d7b4[formerly2de644c9e3] [formerly87aa26bf5a] [formerlyed8b9f5a89[formerly87aa26bf5a[formerly 7a00a651afb1c4251b52a852b01696cc861640be]]]] Former-commit-id:ed8b9f5a89Former-commit-id:bc2ac0198b[formerly7d9eaa94c5] [formerly e2220ff9eabf1270c1ef05bef631dcc980ffdf3f [formerlyb75243d000]] Former-commit-id: d0cb21c209bf1aba3cf62e72c15c150a7d0ca20c [formerlyfa8fe83993] Former-commit-id:1328487a62
This commit is contained in:
Brian Clements
parent
cf95cc9b33
commit
19e686de9b
18 changed files with 0 additions and 1246 deletions
|
|
@ -1,7 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<classpath>
|
|
||||||
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
|
|
||||||
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>
|
|
||||||
<classpathentry kind="src" path="src"/>
|
|
||||||
<classpathentry kind="output" path="bin"/>
|
|
||||||
</classpath>
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<projectDescription>
|
|
||||||
<name>com.raytheon.edex.monitorsrv</name>
|
|
||||||
<comment></comment>
|
|
||||||
<projects>
|
|
||||||
</projects>
|
|
||||||
<buildSpec>
|
|
||||||
<buildCommand>
|
|
||||||
<name>org.eclipse.jdt.core.javabuilder</name>
|
|
||||||
<arguments>
|
|
||||||
</arguments>
|
|
||||||
</buildCommand>
|
|
||||||
<buildCommand>
|
|
||||||
<name>org.eclipse.pde.ManifestBuilder</name>
|
|
||||||
<arguments>
|
|
||||||
</arguments>
|
|
||||||
</buildCommand>
|
|
||||||
<buildCommand>
|
|
||||||
<name>org.eclipse.pde.SchemaBuilder</name>
|
|
||||||
<arguments>
|
|
||||||
</arguments>
|
|
||||||
</buildCommand>
|
|
||||||
</buildSpec>
|
|
||||||
<natures>
|
|
||||||
<nature>org.eclipse.pde.PluginNature</nature>
|
|
||||||
<nature>org.eclipse.jdt.core.javanature</nature>
|
|
||||||
</natures>
|
|
||||||
</projectDescription>
|
|
||||||
|
|
@ -1,7 +0,0 @@
|
||||||
#Thu Mar 26 09:21:50 CDT 2009
|
|
||||||
eclipse.preferences.version=1
|
|
||||||
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
|
|
||||||
org.eclipse.jdt.core.compiler.compliance=1.6
|
|
||||||
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
|
|
||||||
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
|
|
||||||
org.eclipse.jdt.core.compiler.source=1.6
|
|
||||||
|
|
@ -1,15 +0,0 @@
|
||||||
Manifest-Version: 1.0
|
|
||||||
Bundle-ManifestVersion: 2
|
|
||||||
Bundle-Name: Monitorsrv Plug-in
|
|
||||||
Bundle-SymbolicName: com.raytheon.edex.monitorsrv
|
|
||||||
Bundle-Version: 1.12.1174.qualifier
|
|
||||||
Bundle-Vendor: RAYTHEON
|
|
||||||
Export-Package: com.raytheon.edex.monitors,
|
|
||||||
com.raytheon.edex.services
|
|
||||||
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
|
|
||||||
Import-Package: com.raytheon.edex.util,
|
|
||||||
org.apache.commons.logging,
|
|
||||||
org.apache.log4j
|
|
||||||
Require-Bundle: com.raytheon.uf.edex.core;bundle-version="1.12.1174",
|
|
||||||
com.raytheon.uf.edex.database;bundle-version="1.0.0",
|
|
||||||
com.raytheon.uf.common.util;bundle-version="1.12.1174"
|
|
||||||
|
|
@ -1,5 +0,0 @@
|
||||||
source.. = src/
|
|
||||||
output.. = bin/
|
|
||||||
bin.includes = META-INF/,\
|
|
||||||
.,\
|
|
||||||
res/
|
|
||||||
|
|
@ -1,18 +0,0 @@
|
||||||
<beans
|
|
||||||
xmlns="http://www.springframework.org/schema/beans"
|
|
||||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
|
||||||
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
|
|
||||||
|
|
||||||
<bean id="jmxExporter"
|
|
||||||
class="org.springframework.jmx.export.MBeanExporter">
|
|
||||||
<property name="beans">
|
|
||||||
<map>
|
|
||||||
<entry key="log4j:name=settings" value-ref="log4jBean" />
|
|
||||||
</map>
|
|
||||||
</property>
|
|
||||||
</bean>
|
|
||||||
|
|
||||||
<bean id="log4jBean"
|
|
||||||
class="com.raytheon.edex.logging.Log4jLevels" />
|
|
||||||
|
|
||||||
</beans>
|
|
||||||
|
|
@ -1,93 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.logging;
|
|
||||||
|
|
||||||
import org.apache.log4j.Level;
|
|
||||||
import org.apache.log4j.Logger;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Class to modify log4j levels at runtime
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 12/13/07 629 garmendariz Initial check-in
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author garmendariz
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
public class Log4jLevels {
|
|
||||||
|
|
||||||
public String setLevel(String loggerName, String level) {
|
|
||||||
|
|
||||||
if(!checkLevel(level))
|
|
||||||
{
|
|
||||||
return "Can not set level. Valid levels are: debug, info, error, fatal, warn";
|
|
||||||
}
|
|
||||||
|
|
||||||
int nLevel = Level.toLevel(level.toLowerCase()).toInt();
|
|
||||||
|
|
||||||
switch (nLevel) {
|
|
||||||
case Level.DEBUG_INT:
|
|
||||||
Logger.getLogger(loggerName).setLevel(Level.DEBUG);
|
|
||||||
break;
|
|
||||||
case Level.INFO_INT:
|
|
||||||
Logger.getLogger(loggerName).setLevel(Level.INFO);
|
|
||||||
break;
|
|
||||||
case Level.ERROR_INT:
|
|
||||||
Logger.getLogger(loggerName).setLevel(Level.ERROR);
|
|
||||||
break;
|
|
||||||
case Level.FATAL_INT:
|
|
||||||
Logger.getLogger(loggerName).setLevel(Level.FATAL);
|
|
||||||
break;
|
|
||||||
case Level.WARN_INT:
|
|
||||||
Logger.getLogger(loggerName).setLevel(Level.WARN);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
return loggerName + " has been set to " + level + ".\nModify log4j.properties in the Mule conf for permanent changes";
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Check that the level is a valid one
|
|
||||||
* @param level
|
|
||||||
*/
|
|
||||||
private boolean checkLevel(String level) {
|
|
||||||
|
|
||||||
if(level.equalsIgnoreCase("debug") ||
|
|
||||||
level.equalsIgnoreCase("error") ||
|
|
||||||
level.equalsIgnoreCase("debug") ||
|
|
||||||
level.equalsIgnoreCase("fatal") ||
|
|
||||||
level.equalsIgnoreCase("warn") ||
|
|
||||||
level.equalsIgnoreCase("info"))
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,71 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* An abstract base class for EDEX Database Monitors.
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 12May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public abstract class AEdexDBMonitor extends AEdexMonitor {
|
|
||||||
protected String query
|
|
||||||
= "select count(*) from pg_stat_activity where usename='awips' and datname='metadata'";
|
|
||||||
|
|
||||||
protected static final String REPORT_FORMAT = "Database: %s, connections = %s";
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a default object with the default query.
|
|
||||||
*/
|
|
||||||
public AEdexDBMonitor() {
|
|
||||||
// Intentionally empty.
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates an object for the specified query.
|
|
||||||
* @param query
|
|
||||||
*/
|
|
||||||
public AEdexDBMonitor(String query) {
|
|
||||||
this.query = query;
|
|
||||||
}
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
abstract public void execute();
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void setData(String data) {
|
|
||||||
this.query = data;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,88 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import java.io.FilenameFilter;
|
|
||||||
|
|
||||||
import com.raytheon.uf.common.util.file.FilenameFilters;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* An abstract base class for directory monitors.
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 08May2008 1113 MW Fegan Initial creation.
|
|
||||||
* Mar 14, 2013 1794 djohnson Consolidate common FilenameFilter implementations.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public abstract class AEdexDirMonitor extends AEdexMonitor {
|
|
||||||
/** format string for invalid directory messages */
|
|
||||||
protected static final String DIR_ERROR_FORMAT = "Specified path [%s] is not a directory";
|
|
||||||
/** indicates if the directory search is recursive */
|
|
||||||
protected boolean recursive = false;
|
|
||||||
|
|
||||||
/** path to the directory to scan */
|
|
||||||
protected String dirToCheck = ".";
|
|
||||||
|
|
||||||
/* file filter that screens out "dot" files */
|
|
||||||
protected FilenameFilter filter = FilenameFilters.NO_LINUX_HIDDEN_FILES;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Takes no action.
|
|
||||||
*/
|
|
||||||
public AEdexDirMonitor() {
|
|
||||||
// intentionally empty
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Sets the {@code dirToCheck} to the specified value.
|
|
||||||
*/
|
|
||||||
public AEdexDirMonitor(String directory) {
|
|
||||||
this.dirToCheck = directory;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Sets the {@code dirToCheck} and {@code recursive} attributes
|
|
||||||
* to the specified values.
|
|
||||||
*/
|
|
||||||
public AEdexDirMonitor(String directory, String tree) {
|
|
||||||
this.dirToCheck = directory;
|
|
||||||
this.recursive = Boolean.valueOf(tree);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
abstract public void execute();
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
abstract public void setData(String data);
|
|
||||||
}
|
|
||||||
|
|
@ -1,59 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
|
||||||
import org.apache.commons.logging.LogFactory;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* TODO Add Description
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 06May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public abstract class AEdexMonitor implements IEdexMonitor {
|
|
||||||
protected transient Log logger = LogFactory.getLog(getClass());
|
|
||||||
/**
|
|
||||||
* Constructor. Creates an empty object.
|
|
||||||
*/
|
|
||||||
public AEdexMonitor() {
|
|
||||||
/* intentionally empty */
|
|
||||||
}
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.IEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
abstract public void execute();
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.IEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
abstract public void setData(String data);}
|
|
||||||
|
|
@ -1,89 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
import com.raytheon.uf.edex.database.dao.CoreDao;
|
|
||||||
import com.raytheon.uf.edex.database.dao.DaoConfig;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Performs a database monitoring task on the database utilized by the Mule
|
|
||||||
* instance. The number of connections is reported to the system log. The format
|
|
||||||
* of the log message is
|
|
||||||
* <P>
|
|
||||||
* Database: {connection URL}, connections = {count}
|
|
||||||
* <P>
|
|
||||||
* This class is intended to be injected into an {@link MonitorSrv} instance by
|
|
||||||
* Mule. Because of that, all constructor arguments are of type String.
|
|
||||||
* <P>
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 06May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class EdexDBLocalMonitor extends AEdexDBMonitor {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a Local Database Monitor using the default query
|
|
||||||
* string.
|
|
||||||
*/
|
|
||||||
public EdexDBLocalMonitor() {
|
|
||||||
// Intentionally Empty
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a Local Database Monitor using the specified query
|
|
||||||
* string.
|
|
||||||
*
|
|
||||||
* @param query
|
|
||||||
* the monitoring query string
|
|
||||||
*/
|
|
||||||
public EdexDBLocalMonitor(String query) {
|
|
||||||
super(query);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* (non-Javadoc)
|
|
||||||
*
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexDBMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void execute() {
|
|
||||||
CoreDao dao = new CoreDao(DaoConfig.DEFAULT);
|
|
||||||
|
|
||||||
Object[] results = dao.executeSQLQuery(query);
|
|
||||||
if (results == null || results.length == 0) {
|
|
||||||
logger.info("No results returned from query [" + query + "]");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.info(String.format(REPORT_FORMAT, "localhost/"
|
|
||||||
+ DaoConfig.DEFAULT_DB_NAME, results[0].toString()));
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,193 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import java.sql.Connection;
|
|
||||||
import java.sql.DriverManager;
|
|
||||||
import java.sql.ResultSet;
|
|
||||||
import java.sql.SQLException;
|
|
||||||
import java.sql.Statement;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.regex.Matcher;
|
|
||||||
import java.util.regex.Pattern;
|
|
||||||
|
|
||||||
//import com.raytheon.edex.db.dao.CoreDao;
|
|
||||||
//import com.raytheon.edex.db.dao.pool.DaoConfig;
|
|
||||||
//import com.raytheon.edex.db.dao.pool.DaoPool;
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
import com.raytheon.uf.edex.core.EdexException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Performs a database monitoring task on a remote database. This monitor
|
|
||||||
* is intended to allow an instance of EDEX to monitor database connections
|
|
||||||
* on another server. The number of connections is reported to the system
|
|
||||||
* log. The format of the log message is
|
|
||||||
* <P>
|
|
||||||
* Database: {connection URL}, connections = {count}
|
|
||||||
* <P>
|
|
||||||
* This class is intended to be injected into an {@link MonitorSrv} instance by
|
|
||||||
* Mule. Because of that, all constructor arguments are of type String.
|
|
||||||
* <P>
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 12May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class EdexDBRemoteMonitor extends AEdexDBMonitor {
|
|
||||||
private static final String DB_DRIVER = "org.postgresql.Driver";
|
|
||||||
private String connectionURL = "jdbc:postgresql://localhost:5432/metadata";
|
|
||||||
private String user = "awips:awips";
|
|
||||||
|
|
||||||
static {
|
|
||||||
try {
|
|
||||||
Class.forName(DB_DRIVER);
|
|
||||||
} catch (ClassNotFoundException e) {
|
|
||||||
System.out.println(new EdexException("Unable to load PostgresSQL driver",e));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates an empty object.
|
|
||||||
*/
|
|
||||||
public EdexDBRemoteMonitor() {
|
|
||||||
super();
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Initialized the SQL query to the argument.
|
|
||||||
*
|
|
||||||
* @param data SQL string used to monitor the database.
|
|
||||||
*/
|
|
||||||
public EdexDBRemoteMonitor(String query) {
|
|
||||||
super(query);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
* @param url
|
|
||||||
* @param user
|
|
||||||
* @param query
|
|
||||||
*/
|
|
||||||
public EdexDBRemoteMonitor(String url, String user, String query) {
|
|
||||||
super();
|
|
||||||
this.connectionURL = url;
|
|
||||||
this.user = user;
|
|
||||||
this.query = query;
|
|
||||||
}
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.IEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void execute() {
|
|
||||||
Connection conn = null;
|
|
||||||
try {
|
|
||||||
conn = getConnection(connectionURL, user);
|
|
||||||
if (conn == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
List<Object> results = performQuery(conn, query);
|
|
||||||
printResult(results);
|
|
||||||
} finally {
|
|
||||||
closeConnection(conn);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
private void printResult(List<Object> results) {
|
|
||||||
if (results.size() != 1) {
|
|
||||||
logger.warn("obtained invalid result from status query.");
|
|
||||||
}
|
|
||||||
logger.info(String.format(REPORT_FORMAT,connectionURL, results.get(0).toString()));
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
* @param conn
|
|
||||||
* @param query
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
private List<Object> performQuery(Connection conn, String query) {
|
|
||||||
List<Object> retVal = new ArrayList<Object>();
|
|
||||||
Statement s = null;
|
|
||||||
ResultSet r = null;
|
|
||||||
try {
|
|
||||||
s = conn.createStatement();
|
|
||||||
r = s.executeQuery(query);
|
|
||||||
while (r.next()) {
|
|
||||||
retVal.add(r.getObject(1));
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
logger.warn("Encountered problems executing status query",e);
|
|
||||||
} finally {
|
|
||||||
try {
|
|
||||||
if (r != null) {
|
|
||||||
r.close();
|
|
||||||
}
|
|
||||||
if (s != null) {
|
|
||||||
s.close();
|
|
||||||
}
|
|
||||||
} catch (SQLException e) {
|
|
||||||
logger.warn("Unable to close resultset/statement for status query", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return retVal;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
* @param url
|
|
||||||
* @param user
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
private Connection getConnection(String url, String user) {
|
|
||||||
Connection conn = null;
|
|
||||||
try {
|
|
||||||
Pattern p = Pattern.compile("(.+)[:=@](.+)");
|
|
||||||
Matcher m = p.matcher(user);
|
|
||||||
String name = "";
|
|
||||||
String passwd = "";
|
|
||||||
if (m.matches()) {
|
|
||||||
name = m.group(1);
|
|
||||||
passwd = m.group(2);
|
|
||||||
}
|
|
||||||
conn = DriverManager.getConnection(url, name, passwd);
|
|
||||||
} catch (SQLException e) {
|
|
||||||
logger.warn("Unable to create connection to database, url=" + url + ", user=" + user, e);
|
|
||||||
}
|
|
||||||
return conn;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
* @param conn
|
|
||||||
*/
|
|
||||||
private void closeConnection(Connection conn) {
|
|
||||||
if (conn != null) {
|
|
||||||
try {
|
|
||||||
conn.close();
|
|
||||||
} catch (SQLException e) {
|
|
||||||
// can't do much, just log and return
|
|
||||||
logger.warn("Unable to close DB Connection",e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,121 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Performs a count of the files in a directory or directory tree. The total
|
|
||||||
* file count is reported by logging to the application log. The format
|
|
||||||
* of the log message is
|
|
||||||
* <P>
|
|
||||||
* {directory path}: Directory contains {count} files
|
|
||||||
* <P>
|
|
||||||
* File scan defaults to the current directory (not tree search).
|
|
||||||
* <P>
|
|
||||||
* This class is intended to be injected into an {@link MonitorSrv} instance by
|
|
||||||
* Mule. Because of that, all constructor arguments are of type String.
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 08May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class EdexDirCountMonitor extends AEdexDirMonitor {
|
|
||||||
/* format string for reporting statistics */
|
|
||||||
private static final String REPORT_FORMAT = "%s: Directory contains %d files";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor using the defaults.
|
|
||||||
*/
|
|
||||||
public EdexDirCountMonitor() {
|
|
||||||
super();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor for the specified directory.
|
|
||||||
* The scan is non-recursive.
|
|
||||||
*
|
|
||||||
* @param directory the directory to scan.
|
|
||||||
*/
|
|
||||||
public EdexDirCountMonitor(String directory) {
|
|
||||||
super(directory);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor for the specified directory.The second
|
|
||||||
* argument controls scanning depth. Pass "true" to scan the tree, pass
|
|
||||||
* "false" to scan just the specified directory.
|
|
||||||
*
|
|
||||||
* @param path path to the directory to scan
|
|
||||||
* @param tree scan tree flag. Use "true" to scan entire tree.
|
|
||||||
*/
|
|
||||||
public EdexDirCountMonitor(String directory, String tree) {
|
|
||||||
super(directory,tree);
|
|
||||||
}
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.IEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void execute() {
|
|
||||||
File dir = new File(dirToCheck);
|
|
||||||
if (!dir.isDirectory()) {
|
|
||||||
logger.warn(String.format(DIR_ERROR_FORMAT, dirToCheck));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
long count = getCounts(dir,this.recursive);
|
|
||||||
logger.info(String.format(REPORT_FORMAT, dirToCheck, count));
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
* @param dir
|
|
||||||
* @param recursive
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
private long getCounts(File dir,boolean recursive) {
|
|
||||||
long retVal = 0;
|
|
||||||
for(File file : dir.listFiles(filter)){
|
|
||||||
if (recursive && file.isDirectory()) {
|
|
||||||
retVal += getCounts(file,recursive);
|
|
||||||
} else {
|
|
||||||
retVal++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return retVal;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.IEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void setData(String data) {
|
|
||||||
this.dirToCheck = data;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,125 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Performs a file size calculation on a directory or directory tree. The total
|
|
||||||
* file size is reported by logging to the application log. The format
|
|
||||||
* of the log message is
|
|
||||||
* <P>
|
|
||||||
* {directory path}: Total file size {size} bytes
|
|
||||||
* <P>
|
|
||||||
* File scan defaults to the current directory (not tree search).
|
|
||||||
* <P>
|
|
||||||
* This class is intended to be injected into an {@link MonitorSrv} instance by
|
|
||||||
* Mule. Because of that, all constructor arguments are of type String.
|
|
||||||
* <P>
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 08May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class EdexDirSizeMonitor extends AEdexDirMonitor {
|
|
||||||
|
|
||||||
private static final String REPORT_FORMAT = "%s: Total file size %d bytes";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a directory size monitor using the default settings.
|
|
||||||
*/
|
|
||||||
public EdexDirSizeMonitor() {
|
|
||||||
super();
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a directory size monitor for the specified directory.
|
|
||||||
* The scan is limited to the specified directory.
|
|
||||||
*
|
|
||||||
* @param directory path to the directory to scan
|
|
||||||
*/
|
|
||||||
public EdexDirSizeMonitor(String directory) {
|
|
||||||
super(directory);
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a directory size monitor for the specified directory.
|
|
||||||
* The second argument controls scanning depth. Pass "true" to scan the tree,
|
|
||||||
* pass "false" to scan just the specified directory.
|
|
||||||
*
|
|
||||||
* @param directory path to the directory to scan
|
|
||||||
* @param tree scan tree flag. Use "true" to scan entire tree.
|
|
||||||
*/
|
|
||||||
public EdexDirSizeMonitor(String directory, String tree) {
|
|
||||||
super(directory,tree);
|
|
||||||
}
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void execute() {
|
|
||||||
File dir = new File(dirToCheck);
|
|
||||||
if (!dir.isDirectory()) {
|
|
||||||
logger.warn(String.format(DIR_ERROR_FORMAT, dirToCheck));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
long size = getSizes(dir,this.recursive);
|
|
||||||
logger.info(String.format(REPORT_FORMAT, dirToCheck,size));
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Finds the total size of the files in a directory. Recursively
|
|
||||||
* scans the directory and finds the total number of bytes in the
|
|
||||||
* files in the directory. Setting the recursive flag to false limits
|
|
||||||
* the search to a single directory.
|
|
||||||
*
|
|
||||||
* @param dir the directory to search
|
|
||||||
* @param recursive set true to search entire tree
|
|
||||||
*
|
|
||||||
* @return number of bytes used by files in the directory
|
|
||||||
*/
|
|
||||||
private long getSizes(File dir, boolean recursive) {
|
|
||||||
long retVal = 0;
|
|
||||||
for(File file : dir.listFiles(filter)){
|
|
||||||
if (recursive && file.isDirectory()) {
|
|
||||||
retVal += getSizes(file,recursive);
|
|
||||||
} else {
|
|
||||||
retVal += file.length();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return retVal;
|
|
||||||
}
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void setData(String data) {
|
|
||||||
dirToCheck = data;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,194 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.net.MalformedURLException;
|
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
import javax.management.MBeanServerConnection;
|
|
||||||
import javax.management.ObjectName;
|
|
||||||
import javax.management.remote.JMXConnector;
|
|
||||||
import javax.management.remote.JMXConnectorFactory;
|
|
||||||
import javax.management.remote.JMXServiceURL;
|
|
||||||
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
import com.raytheon.uf.common.util.StringUtil;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Uses JMX to obtain latency information for an end-point. Reports queue size,
|
|
||||||
* event backlog and average execution time for the end-point. The format of the
|
|
||||||
* log message is
|
|
||||||
* <P>
|
|
||||||
* {end-point name}: Queue Size = {count}, Event Backlog = {count}, Average Execution Time = {count}
|
|
||||||
* <P>
|
|
||||||
* The monitoring defaults to the current Mule instance on the local computer.
|
|
||||||
* There is no default for the end-point parameter.
|
|
||||||
* <P>
|
|
||||||
* This class is intended to be injected into an {@link MonitorSrv} instance by
|
|
||||||
* Mule. Because of that, all constructor arguments are of type String.
|
|
||||||
* <P>
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 07May2008 1113 MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class EdexLatencyMonitor extends AEdexMonitor {
|
|
||||||
/* format string for creating the connection URL */
|
|
||||||
private static final String URL_FORMAT = "service:jmx:rmi://%s/jndi/rmi://%s:%s/%s";
|
|
||||||
/* format string for reporting statistics */
|
|
||||||
private static final String REPORT_FORMAT = "%s: Queue Size = %d, Event Backlog = %d, Average Execution Time = %d";
|
|
||||||
/** host name for connection string */
|
|
||||||
private String server = "localhost";
|
|
||||||
/** port for connection string */
|
|
||||||
private String port = "1099";
|
|
||||||
/** application for connection string */
|
|
||||||
private String application = "Mule";
|
|
||||||
/** complete connection URL */
|
|
||||||
private String strurl = String.format(URL_FORMAT, server,server,port,application);
|
|
||||||
/** name of end-point to monitor */
|
|
||||||
private String beanName = null;
|
|
||||||
|
|
||||||
MBeanServerConnection connection = null;
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor using defaults.
|
|
||||||
*/
|
|
||||||
public EdexLatencyMonitor() {
|
|
||||||
// intentionally empty
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor for the specified end-point. The monitor uses
|
|
||||||
* the default connection URL.
|
|
||||||
*
|
|
||||||
* @param beanName name of end-point to monitor
|
|
||||||
*/
|
|
||||||
public EdexLatencyMonitor(String beanName) {
|
|
||||||
this.beanName = beanName;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor for the specified Mule instance using the
|
|
||||||
* specified end-point.
|
|
||||||
*
|
|
||||||
* @param server the server hosting the mule instance
|
|
||||||
* @param port the port to which Mule is listening
|
|
||||||
* @param application the Mule application identifier (usually "Mule")
|
|
||||||
* @param beanName name of end-point to monitor
|
|
||||||
*/
|
|
||||||
public EdexLatencyMonitor(String server, String port, String application, String beanName) {
|
|
||||||
this.server = server;
|
|
||||||
this.port = port;
|
|
||||||
this.application = application;
|
|
||||||
this.strurl = String.format(URL_FORMAT, server,server,port,application);
|
|
||||||
this.beanName = beanName;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Constructor. Creates a monitor for the specified connection URL using the
|
|
||||||
* specified end-point. The format of the connection URL is
|
|
||||||
* <P>
|
|
||||||
* service:jmx:rmi://{server}/jndi/rmi://{server}:{port}/{application}
|
|
||||||
*
|
|
||||||
* @param strurl the connection URL
|
|
||||||
* @param beanName name of end-point to monitor
|
|
||||||
*/
|
|
||||||
public EdexLatencyMonitor(String strurl, String beanName) {
|
|
||||||
this.strurl = strurl;
|
|
||||||
this.beanName = beanName;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Initializes the JMX connection.
|
|
||||||
*/
|
|
||||||
private void init() {
|
|
||||||
if (this.connection != null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
JMXConnector connector = null;
|
|
||||||
try {
|
|
||||||
JMXServiceURL url = new JMXServiceURL(strurl);
|
|
||||||
connector = JMXConnectorFactory.connect(url);
|
|
||||||
} catch (MalformedURLException e) {
|
|
||||||
logger.warn(connection + "is invalid",e);
|
|
||||||
} catch (IOException e) {
|
|
||||||
logger.warn("Unable to connect to " + strurl,e);
|
|
||||||
}
|
|
||||||
if (connector != null) {
|
|
||||||
try {
|
|
||||||
this.connection = connector.getMBeanServerConnection();
|
|
||||||
} catch (IOException e) {
|
|
||||||
logger.warn("Unable to create connection to " + strurl,e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#execute()
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void execute() {
|
|
||||||
init();
|
|
||||||
if (this.connection == null) {
|
|
||||||
logger.warn("connection to " + strurl + " is unavailable, unable to monitor");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
String[] domainNames = this.connection.getDomains();
|
|
||||||
String domainName = "";
|
|
||||||
for (String name : domainNames) {
|
|
||||||
if (name.startsWith("Mule")) {
|
|
||||||
domainName = name;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
String objStr = domainName+":type=org.mule.Component,name=\""+beanName+"\"";
|
|
||||||
Set<ObjectName> sets = null;
|
|
||||||
ObjectName obName = new ObjectName(objStr);
|
|
||||||
sets = this.connection.queryNames(obName, null);
|
|
||||||
if (sets.size() != 1) {
|
|
||||||
logger.warn("unable to get access to " + objStr);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
ObjectName theObject = (ObjectName)sets.toArray()[0];
|
|
||||||
Integer queueSize = (Integer)connection.getAttribute(theObject, "QueueSize");
|
|
||||||
Long queuedEvents = (Long)connection.getAttribute(theObject, "QueuedEvents");
|
|
||||||
Long averageTime = (Long)connection.getAttribute(theObject, "AverageExecutionTime");
|
|
||||||
logger.info(String.format(REPORT_FORMAT,StringUtil.printString(beanName),
|
|
||||||
queueSize,queuedEvents,averageTime));
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see com.raytheon.edex.monitors.AEdexMonitor#setData(java.lang.String)
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void setData(String data) {
|
|
||||||
this.beanName = data;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,54 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.monitors;
|
|
||||||
|
|
||||||
import com.raytheon.edex.services.MonitorSrv;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Specifies the interface defining the capabilities of the EDEX monitor
|
|
||||||
* classes. These are used by the {@link MonitorSrv} to monitor and report
|
|
||||||
* various system conditions.
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
*
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 02May2008 TBD MW Fegan Initial creation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public interface IEdexMonitor {
|
|
||||||
/**
|
|
||||||
* Sets the user data from the monitor. This should be called just
|
|
||||||
* prior to running the {@link #execute()} method.
|
|
||||||
* @param data the data to provide to the monitor
|
|
||||||
*/
|
|
||||||
public void setData(final String data);
|
|
||||||
/**
|
|
||||||
* Triggers a single monitoring event in the monitor.
|
|
||||||
*/
|
|
||||||
public void execute();
|
|
||||||
}
|
|
||||||
|
|
@ -1,79 +0,0 @@
|
||||||
/**
|
|
||||||
* This software was developed and / or modified by Raytheon Company,
|
|
||||||
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
||||||
*
|
|
||||||
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
||||||
* This software product contains export-restricted data whose
|
|
||||||
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
||||||
* to non-U.S. persons whether in the United States or abroad requires
|
|
||||||
* an export license or other authorization.
|
|
||||||
*
|
|
||||||
* Contractor Name: Raytheon Company
|
|
||||||
* Contractor Address: 6825 Pine Street, Suite 340
|
|
||||||
* Mail Stop B8
|
|
||||||
* Omaha, NE 68106
|
|
||||||
* 402.291.0100
|
|
||||||
*
|
|
||||||
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
||||||
* further licensing information.
|
|
||||||
**/
|
|
||||||
package com.raytheon.edex.services;
|
|
||||||
|
|
||||||
import com.raytheon.edex.monitors.IEdexMonitor;
|
|
||||||
import com.raytheon.uf.edex.core.EdexException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* This is a service endpoint for EDEX monitoring. It receives an
|
|
||||||
* {@link IEdexMonitor} instance by injection and calls the
|
|
||||||
* {@link IEdexMonitor#execute()} method. All error handling is managed here as
|
|
||||||
* well.
|
|
||||||
* <P>
|
|
||||||
*
|
|
||||||
* <pre>
|
|
||||||
*
|
|
||||||
* SOFTWARE HISTORY
|
|
||||||
* Date Ticket# Engineer Description
|
|
||||||
* ------------ ---------- ----------- --------------------------
|
|
||||||
* 02May2008 1113 MW Fegan Initial implementation.
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author mfegan
|
|
||||||
* @version 1.0
|
|
||||||
*/
|
|
||||||
|
|
||||||
public class MonitorSrv {
|
|
||||||
private IEdexMonitor edexMonitor = null;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructor. Creates an empty end-point ready for use by Mule.
|
|
||||||
*/
|
|
||||||
public MonitorSrv() {
|
|
||||||
// Intentionally empty.
|
|
||||||
}
|
|
||||||
|
|
||||||
public void process() throws EdexException {
|
|
||||||
if (edexMonitor == null) {
|
|
||||||
throw new EdexException("Monitor is null - unable to process");
|
|
||||||
}
|
|
||||||
edexMonitor.execute();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the {@link IEdexMonitor} instance used by this end-point.
|
|
||||||
*/
|
|
||||||
public IEdexMonitor getEdexMonitor() {
|
|
||||||
return edexMonitor;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sets the {@link IEdexMonitor} instance for the monitor to use.
|
|
||||||
* <P>
|
|
||||||
* Note: This is provided to allow dependency injection by the container.
|
|
||||||
*/
|
|
||||||
public void setEdexMonitor(IEdexMonitor edexMonitor) {
|
|
||||||
this.edexMonitor = edexMonitor;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
Loading…
Add table
Reference in a new issue