src/main/java/org/apache/felix/ipojo/handler/wbp/WhiteBoardManager.java

/* 
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.felix.ipojo.handler.wbp;

import java.lang.reflect.InvocationTargetException;

import org.apache.felix.ipojo.PrimitiveHandler;
import org.apache.felix.ipojo.util.Callback;
import org.apache.felix.ipojo.util.Tracker;
import org.apache.felix.ipojo.util.TrackerCustomizer;
import org.osgi.framework.Filter;
import org.osgi.framework.ServiceReference;

/**
 * Manage a white board pattern.
 * @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
 */
public class WhiteBoardManager implements TrackerCustomizer {
    
    /**
     * monitored filter. 
     */
    private Filter m_filter;
    
    /**
     * onArrival method. 
     */
    private Callback m_onArrival;
    
    /**
     * onDeparture method. 
     */
    private Callback m_onDeparture;
    
    /**
     * onModify method. 
     */
    private Callback m_onModification;
    
    /**
     * Service Tracker. 
     */
    private Tracker m_tracker;
    
    /**
     * Attached handler. 
     */
    private PrimitiveHandler m_handler;
    
    /**
     * Constructor.
     * @param handler : attached handler
     * @param filter : monitored filter
     * @param bind : onArrival method
     * @param unbind : onDeparture method
     * @param modification : onModify method
     */
    public WhiteBoardManager(WhiteBoardPatternHandler handler, Filter filter, String bind, String unbind, String modification) {
        m_handler = handler;
        m_onArrival = new Callback(bind, new Class[] {ServiceReference.class}, false, m_handler.getInstanceManager());
        m_onDeparture = new Callback(unbind, new Class[] {ServiceReference.class}, false, m_handler.getInstanceManager());
        if (modification != null) {
            m_onModification = new Callback(modification, new Class[] {ServiceReference.class}, false, m_handler.getInstanceManager());
        }
        m_filter = filter;
        m_tracker = new Tracker(handler.getInstanceManager().getContext(), m_filter, this);
    }
    
    /**
     * Open the tracker.
     */
    public void start() {
        m_tracker.open();
    }
    
    /**
     * Close the tracker.
     */
    public void stop() {
        m_tracker.close();
    }

    /**
     * A new service was added to the tracker.
     * @param arg0 : service reference.
     * @see org.apache.felix.ipojo.util.TrackerCustomizer#addedService(org.osgi.framework.ServiceReference)
     */
    public void addedService(ServiceReference arg0) {
        try {
            m_onArrival.call(new Object[] {arg0});
        } catch (NoSuchMethodException e) {
            m_handler.error("The onArrival method " + m_onArrival.getMethod() + " does not exist in the class", e);
            m_handler.getInstanceManager().stop();
        } catch (IllegalAccessException e) {
            m_handler.error("The onArrival method " + m_onArrival.getMethod() + " cannot be invoked", e);
            m_handler.getInstanceManager().stop();
        } catch (InvocationTargetException e) {
            m_handler.error("The onArrival method " + m_onArrival.getMethod() + " has thrown an exception", e.getTargetException());
            m_handler.getInstanceManager().stop();
        }
    }

    /**
     * A new service is detected.
     * @param arg0 : service reference
     * @return true to add the service
     * @see org.apache.felix.ipojo.util.TrackerCustomizer#addingService(org.osgi.framework.ServiceReference)
     */
    public boolean addingService(ServiceReference arg0) {
        return true;
    }

    /**
     * An existing service was modified.
     * @param arg0 : service reference
     * @param arg1 : service object (if already get)
     * @see org.apache.felix.ipojo.util.TrackerCustomizer#modifiedService(org.osgi.framework.ServiceReference, java.lang.Object)
     */
    public void modifiedService(ServiceReference arg0, Object arg1) {
        if (m_onModification != null) {
            try {
                m_onModification.call(new Object[] {arg0});
            } catch (NoSuchMethodException e) {
                m_handler.error("The onModification method " + m_onModification.getMethod() + " does not exist in the class", e);
                m_handler.getInstanceManager().stop();
            } catch (IllegalAccessException e) {
                m_handler.error("The onModification method " + m_onModification.getMethod() + " cannot be invoked", e);
                m_handler.getInstanceManager().stop();
            } catch (InvocationTargetException e) {
                m_handler.error("The onModification method " + m_onModification.getMethod() + " has thrown an exception", e.getTargetException());
                m_handler.getInstanceManager().stop();
            }
        }
    }

    /**
     * A service disappears.
     * @param arg0 : service reference
     * @param arg1 : service object (if already get)
     * @see org.apache.felix.ipojo.util.TrackerCustomizer#removedService(org.osgi.framework.ServiceReference, java.lang.Object)
     */
    public void removedService(ServiceReference arg0, Object arg1) {
        try {
            m_onDeparture.call(new Object[] {arg0});
        } catch (NoSuchMethodException e) {
            m_handler.error("The onDeparture method " + m_onDeparture.getMethod() + " does not exist in the class", e);
            m_handler.getInstanceManager().stop();
        } catch (IllegalAccessException e) {
            m_handler.error("The onDeparture method " + m_onDeparture.getMethod() + " cannot be invoked", e);
            m_handler.getInstanceManager().stop();
        } catch (InvocationTargetException e) {
            m_handler.error("The onDeparture method " + m_onDeparture.getMethod() + " has thrown an exception", e.getTargetException());
            m_handler.getInstanceManager().stop();
        }
    }

}