|
|
|
@ -4,11 +4,11 @@ import com.fr.design.record.analyzer.DesignerAnalyzerAdvice;
|
|
|
|
|
import com.fr.general.GeneralUtils; |
|
|
|
|
import com.fr.intelli.measure.Estimator; |
|
|
|
|
import com.fr.intelli.metrics.Compute; |
|
|
|
|
import com.fr.intelli.metrics.MessageRecorderFactory; |
|
|
|
|
import com.fr.intelli.metrics.SupervisoryConfig; |
|
|
|
|
import com.fr.intelli.record.Measurable; |
|
|
|
|
import com.fr.intelli.record.MeasureObject; |
|
|
|
|
import com.fr.intelli.record.MeasureUnit; |
|
|
|
|
import com.fr.intelli.record.MetricRegistry; |
|
|
|
|
import com.fr.log.FineLoggerFactory; |
|
|
|
|
import com.fr.measure.DBMeterFactory; |
|
|
|
|
import com.fr.stable.ArrayUtils; |
|
|
|
@ -80,18 +80,16 @@ public class MonitorAdvice implements DesignerAnalyzerAdvice {
|
|
|
|
|
List<Object> newArgs = new ArrayList<>(Arrays.asList(args)); |
|
|
|
|
newArgs.add(id); |
|
|
|
|
recordSQLDetail(id); |
|
|
|
|
if (measurable instanceof Estimator) { |
|
|
|
|
measurable.asyncDurable(measureObject, newArgs.toArray()); |
|
|
|
|
} else { |
|
|
|
|
Object message = null; |
|
|
|
|
try { |
|
|
|
|
message = measurable.durableEntity(measureObject, newArgs.toArray()); |
|
|
|
|
} catch (Throwable throwable) { |
|
|
|
|
FineLoggerFactory.getLogger().error(throwable.getMessage(), throwable); |
|
|
|
|
} |
|
|
|
|
if (message != null) { |
|
|
|
|
MetricRegistry.getMetric().submit(message); |
|
|
|
|
} |
|
|
|
|
if (measurable instanceof Estimator) { |
|
|
|
|
MessageRecorderFactory.getInstance().asyncSubmit(message); |
|
|
|
|
} else { |
|
|
|
|
MessageRecorderFactory.getInstance().syncSubmit(message); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} catch (Exception ignore) { |
|
|
|
|