/* * JBoss, Home of Professional Open Source. * Copyright 2006, Red Hat Middleware LLC, and individual contributors * as indicated by the @author tags. See the copyright.txt file in the * distribution for a full listing of individual contributors. * * This 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, or (at your option) any later version. * * This software 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 Lesser General Public * License along with this software; if not, write to the Free * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ package javax.management; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.io.ObjectStreamField; import java.util.Set; import java.util.HashSet; import java.util.Vector; /** * Notification filter support for attribute change notifications. * * @see javax.management.AttributeChangeNotification * @see javax.management.NotificationFilter * * @author Juha Lindfors. * @author a href="mailto:Adrian.Brock@HappeningTimes.com">Adrian Brock * @version $Revision: 57200 $ * *

Revisions: *

20020710 Adrian Brock: *

*/ public class AttributeChangeNotificationFilter implements NotificationFilter, java.io.Serializable { // Constants ----------------------------------------------------- private static final long serialVersionUID = -6347317584796410029L; private static final ObjectStreamField[] serialPersistentFields = new ObjectStreamField[] { new ObjectStreamField("enabledAttributes", Vector.class) }; // Attributes ---------------------------------------------------- private Set attributes = new HashSet(); // Constructors -------------------------------------------------- /** * Constructs an attribute change notification filter. All attribute * notifications are filtered by default. Use {@link #enableAttribute} * to enable notifications of a given attribute to pass this filter. */ public AttributeChangeNotificationFilter() { } // NotificationFilter implementation ----------------------------- public synchronized boolean isNotificationEnabled(Notification notification) { if (notification != null && notification instanceof AttributeChangeNotification) { AttributeChangeNotification notif = (AttributeChangeNotification)notification; if (attributes.contains(notif.getAttributeName())) return true; } return false; } // Public -------------------------------------------------------- /** * Enables the attribute change notifications of the given attribute to be * sent to the listener. * * @param name name of the management attribute */ public synchronized void enableAttribute(String name) throws IllegalArgumentException { if (name == null) throw new IllegalArgumentException("Null attribute name"); attributes.add(name); } /** * Disable the attribute change notifications of the given attribute. * Attribute change notifications for this attribute will not be sent to * the listener. * * @param name name of the management attribute */ public synchronized void disableAttribute(String name) { attributes.remove(name); } /** * Disables all attribute change notifications. */ public synchronized void disableAllAttributes() { attributes.clear(); } /** * Returns the names of the attributes whose notifications are allowed to * pass this filter. * * @return a vector containing the name strings of the enabled attributes */ public synchronized Vector getEnabledAttributes() { return new Vector(attributes); } /** * @return human readable string. */ public String toString() { StringBuffer buffer = new StringBuffer(100); buffer.append(getClass().getName()).append(":"); buffer.append(" enabledAttributes=").append(getEnabledAttributes()); return buffer.toString(); } // Private ------------------------------------------------------- private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException { ObjectInputStream.GetField getField = ois.readFields(); Vector enabled = (Vector) getField.get("enabledAttributes", null); attributes = new HashSet(enabled); } private void writeObject(ObjectOutputStream oos) throws IOException { ObjectOutputStream.PutField putField = oos.putFields(); putField.put("enabledAttributes", new Vector(attributes)); oos.writeFields(); } }