compositeoppmessagelistener.java

来自「Java的面向对象数据库系统的源代码」· Java 代码 · 共 69 行

// You can redistribute this software and/or modify it under the terms of
// the Ozone Library License version 1 published by ozone-db.org.
//
// The original code and portions created by SMB are
// Copyright (C) 1997-@year@ by SMB GmbH. All rights reserved.
//
// $Id: $
package org.ozoneDB.tools.OPP.message;

import org.ozoneDB.tools.OPP.message.MessageWriter;

import java.util.Set;
import java.util.HashSet;
import java.util.Iterator;

public class CompositeOPPMessageListener implements MessageWriter {
    Set listeners = new HashSet();

    public void startGeneration(String object) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).startGeneration(object);
        }
    }

    public void error(String message) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).error(message);
        }
    }

    public void warning(String message) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).warning(message);
        }
    }

    public void warning(String filename, int row, String message) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).warning(filename, row, message);
        }
    }

    public void info(String message) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).info(message);
        }
    }

    public void debug(String message) {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).debug(message);
        }
    }

    public void endGeneration() {
        for (Iterator iter = listeners.iterator(); iter.hasNext();) {
            ((MessageWriter) iter.next()).endGeneration();
        }
    }

    public void addListener(MessageWriter listener) {
        listeners.add(listener);
    }

    public void removeListener(MessageWriter listener) {
        listeners.remove(listener);
    }
}