| gvSIG desktop 1

package com.iver.andami.messages;

import org.apache.log4j.Logger;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.util.ArrayList;

import java.util.Vector;

import javax.swing.Timer;

/**

 * Clase que recibe los mensajes de error, warning e informaci?n y dispara los

 * eventos en los listeners que escuchan dichos eventos

 *

 * @version $Revision: 598 $

 */

public class NotificationManager {

    /** DOCUMENT ME! */

    private static Logger logger = Logger.getLogger(NotificationManager.class.getName());

    /** Timer de espera de nuevos mensajes */

    private static Timer timer;

    /** Indica si se han a?adido mensajes desde la ?ltima vez que se comprob? */

    private static boolean addedMessage = false;

    /** DOCUMENT ME! */

    private static ArrayList info = new ArrayList();

    private static ArrayList infoExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static ArrayList warnings = new ArrayList();

    private static ArrayList warningsExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static ArrayList errors = new ArrayList();

    private static ArrayList errorsExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static Vector listeners = new Vector();

    private static boolean isFirst = true;

    /**

     * A?ade un objeto que escucha los mensajes de error, warning e informaci?n

     *

     * @param nl objeto que recibir? los eventos

     */

    public static synchronized void addNotificationListener(NotificationListener nl) {

        logger.info("Se a?ade un listener al manager de notificaciones");

        listeners.add(nl);

    }

    /**

     * @see com.iver.mdiApp.Notification#addError(java.lang.String)

     */

    public static synchronized void addError(final String err, Throwable e) {

            logger.debug(err,e);

        errors.add(err);

        errorsExceptions.add(e);

        if (isFirst) {

            AddError((String[]) errors.toArray(new String[0]),

                (Throwable[]) errorsExceptions.toArray(new Throwable[0]));

            errors.clear();

            errorsExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /**

     * @see com.iver.mdiApp.Notification#addWarning(java.lang.String)

     */

    public static synchronized void addWarning(final String warn, final Throwable e) {

                logger.debug(warn,e);

        warnings.add(warn);

        warningsExceptions.add(e);

        if (isFirst) {

            AddWarning((String[]) warnings.toArray(new String[0]),

                (Throwable[]) warningsExceptions.toArray(new Throwable[0]));

            warnings.clear();

            warningsExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /**

     * @see com.iver.mdiApp.Consola#addInfo(java.lang.String)

     */

    public static synchronized void addInfo(final String inf, final Throwable e) {

                logger.debug(inf,e);

        info.add(inf);

        infoExceptions.add(e);

        if (isFirst) {

            AddInfo((String[]) info.toArray(new String[0]),

                (Throwable[]) infoExceptions.toArray(new Throwable[0]));

            info.clear();

            infoExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de error a todos los listeners registrados

     *

     * @param error Mensaje de error

     * @param e s que van a recibir las notificaciones

     */

    private static void AddError(String[] error, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).errorEvent(new MessageEvent(

                    error, e));

        }

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de error a todos los listeners registrados

     *

     * @param warn Mensaje de warning

     * @param e objetos que van a recibir las notificaciones

     */

    private static void AddWarning(String[] warn, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).warningEvent(new MessageEvent(

                    warn, e));

        }

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de informaci?n a todos los listeners registrados

     *

     * @param info Mensaje de informaci?n

     * @param e objetos que van a recibir las notificaciones

     */

    private static void AddInfo(String[] info, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).infoEvent(new MessageEvent(

                    info, e));

        }

    }

    /**

     * DOCUMENT ME!

     */

    private static void dispatchMessages() {

        addedMessage = true;

        if (timer == null) {

            System.err.println("Se pone el timer");

            timer = new Timer(1000, new ActionListener() {

                                public void actionPerformed(ActionEvent e) {

                                if (errors.size() > 0) {

                                    AddError((String[]) errors.toArray(new String[0]),

                                        (Throwable[]) errorsExceptions.toArray(new Throwable[0]));

                                    errors.clear();

                                    errorsExceptions.clear();

                                }

                                if (warnings.size() > 0) {

                                    AddWarning((String[]) warnings.toArray(new String[0]),

                                        (Throwable[]) warningsExceptions.toArray(new Throwable[0]));

                                    warnings.clear();

                                    warningsExceptions.clear();

                                }

                                if (info.size() > 0) {

                                    AddInfo((String[]) info.toArray(new String[0]),

                                        (Throwable[]) infoExceptions.toArray(new Throwable[0]));

                                    info.clear();

                                    infoExceptions.clear();

                                }

                                if (!addedMessage) {

                                    if (timer != null) {

                                        timer.stop();

                                    }

                                    timer = null;

                                }

                                addedMessage = false;

                                isFirst = true;

                                }

                        });

            timer.start();

        }

    }

}