mrelation.java

基于java地snmpMIB地访问地实现,已经使用了较长时间.

/*
 * Copyright (c) 2002-2003 UTStarcom, Inc.
 * All rights reserved.
 */
package core.relation.mrelation;

import core.relation.common.Relation;
import core.relation.common.Body;
import core.relation.common.FilterBody;
import core.relation.common.MessageFilter;

import java.util.Vector;
import java.util.Iterator;
import java.util.LinkedList;

/**
 * The MRelation class.
 *
 * @author Heter pan
 */
public class MRelation implements Relation {
    LinkedList elements;

    public MRelation() {
        elements = new LinkedList();
    }

    public void addElement( Body b ) {
        elements.addLast( b );
    }

    public void removeElement( Body b ) {
        elements.remove( b );
    }

    public void send( Object message ) {
        Iterator i = elements.iterator();
        while ( i.hasNext() ) {
            FilterBody b = ( FilterBody ) i.next();
            MessageFilter mf = b.getFilter();
            if ( mf.filter( message ) ) {
                b.receive( message );
                break;
            }
        }
    }

}