allstatistics.java

提供ESB 应用mule源代码 提供ESB 应用mule源代码

/*
 * $Id: AllStatistics.java 10529 2008-01-25 05:58:36Z dfeist $
 * --------------------------------------------------------------------------------------
 * Copyright (c) MuleSource, Inc.  All rights reserved.  http://www.mulesource.com
 *
 * The software in this package is published under the terms of the CPAL v1.0
 * license, a copy of which has been included with this distribution in the
 * LICENSE.txt file.
 */

package org.mule.management.stats;

import org.mule.api.management.stats.Statistics;
import org.mule.management.stats.printers.AbstractTablePrinter;
import org.mule.management.stats.printers.SimplePrinter;

import java.io.PrintWriter;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;

/**
 * <code>AllStatistics</code> TODO
 */
public class AllStatistics
{
    private boolean isStatisticsEnabled;
    private long startTime;

    private HashMap componentStat = new HashMap();

    /**
     * 
     */
    public AllStatistics()
    {
        clear();
    }

    public void logSummary()
    {
        logSummary(new SimplePrinter(System.out));
    }

    public void logSummary(PrintWriter printer)
    {

        if (printer instanceof AbstractTablePrinter)
        {
            printer.print(componentStat.values());
        }
        else
        {
            Iterator it = componentStat.values().iterator();

            while (it.hasNext())
            {
                printer.print(it.next());
            }
        }
        // printer.println("-----------------------------");
        // printer.println("duration (ms): " + (System.currentTimeMillis() -
        // startTime));
    }

    public synchronized void clear()
    {

        Iterator it = getComponentStatistics().iterator();

        while (it.hasNext())
        {
            ((Statistics) it.next()).clear();
        }
        startTime = System.currentTimeMillis();
    }

    /**
     * Are statistics logged
     */
    public boolean isEnabled()
    {
        return isStatisticsEnabled;
    }

    /**
     * Enable statistics logs (this is a dynamic parameter)
     */
    public void setEnabled(boolean b)
    {
        isStatisticsEnabled = b;

        Iterator it = componentStat.values().iterator();

        while (it.hasNext())
        {
            ((ServiceStatistics) it.next()).setEnabled(b);
        }
    }

    public synchronized long getStartTime()
    {
        return startTime;
    }

    public synchronized void setStartTime(long startTime)
    {
        this.startTime = startTime;
    }

    public synchronized void add(ServiceStatistics stat)
    {
        if (stat != null)
        {
            componentStat.put(stat.getName(), stat);
        }
    }

    public synchronized void remove(ServiceStatistics stat)
    {
        if (stat != null)
        {
            componentStat.remove(stat.getName());
        }
    }

    public synchronized Collection getComponentStatistics()
    {
        return componentStat.values();
    }

}