Edit C:\galaxie\jobs\MAURY_GUIDE_EXPORT_2023_0.2\MAURY_GUIDE_EXPORT_2019\src\main\java\routines\system\StatCatcherUtils.java
// ============================================================================ // // Talend Community Edition // // Copyright (C) 2006-2015 Talend - www.talend.com // // This library is free software; you can redistribute it and/or // modify it under the terms of the GNU Lesser General Public // License as published by the Free Software Foundation; either // version 2.1 of the License. // // This library is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU // Lesser General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program; if not, write to the Free Software // Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. // // ============================================================================ package routines.system; import java.lang.management.ManagementFactory; import java.lang.management.RuntimeMXBean; import java.util.Date; public class StatCatcherUtils { public class StatCatcherMessage { private String origin; private String message; private Long duration = null; private Date moment; private String messageType; private String jobVersion; private String jobId; private Long systemPid; public StatCatcherMessage(String message, String messageType, String origin, Long duration, String jobVersion, String jobId) { this.origin = origin; this.message = message; this.duration = duration; this.moment = java.util.Calendar.getInstance().getTime(); this.messageType = messageType; this.jobVersion = jobVersion; this.jobId = jobId; this.systemPid = StatCatcherUtils.getPid(); } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public String getOrigin() { return origin; } public void setOrigin(String origin) { this.origin = origin; } public Date getMoment() { return moment; } public void setMoment(Date d) { this.moment = d; } public Long getDuration() { return duration; } public void setDuration(Long duration) { this.duration = duration; } public String getJobId() { return jobId; } public void setJobId(String jobId) { this.jobId = jobId; } public String getJobVersion() { return jobVersion; } public void setJobVersion(String jobVersion) { this.jobVersion = jobVersion; } public String getMessageType() { return messageType; } public void setMessageType(String messageType) { this.messageType = messageType; } public Long getSystemPid() { return systemPid; } public void setSystemPid(Long systemPid) { this.systemPid = systemPid; } } java.util.List<StatCatcherMessage> messages = java.util.Collections .synchronizedList(new java.util.ArrayList<StatCatcherMessage>()); String jobId = ""; //$NON-NLS-1$ String jobVersion = ""; //$NON-NLS-1$ public StatCatcherUtils(String jobId, String jobVersion) { this.jobId = jobId; this.jobVersion = jobVersion; } public void addMessage(String message, String origin, Long duration) { String messageType = ""; //$NON-NLS-1$ if (message.compareTo("begin") == 0) { //$NON-NLS-1$ messageType = message; message = null; } else if (message.compareTo("end") == 0) { //$NON-NLS-1$ messageType = message; message = "success"; //$NON-NLS-1$ } else if (message.compareTo("failure") == 0) { //$NON-NLS-1$ messageType = "end"; //$NON-NLS-1$ } StatCatcherMessage scm = new StatCatcherMessage(message, messageType, origin, duration, this.jobVersion, this.jobId); messages.add(scm); } public void addMessage(String message, String origin) { addMessage(message, origin, null); } public void addMessage(String message, Long duration) { addMessage(message, "", duration); //$NON-NLS-1$ } public void addMessage(String message) { addMessage(message, "", null); //$NON-NLS-1$ } public java.util.List<StatCatcherMessage> getMessages() { java.util.List<StatCatcherMessage> messagesToSend = new java.util.ArrayList<StatCatcherMessage>(); synchronized (messages) { for (StatCatcherMessage scm : messages) { messagesToSend.add(scm); } messages.clear(); } return messagesToSend; } public static long getPid() { RuntimeMXBean mx = ManagementFactory.getRuntimeMXBean(); String[] mxNameTable = mx.getName().split("@"); //$NON-NLS-1$ if (mxNameTable.length == 2) { return Long.parseLong(mxNameTable[0]); } else { return Thread.currentThread().getId(); } } }
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de