org.apache.felix.upnp.tester/src/main/java/org/apache/felix/upnp/tester/UPnPSubscriber.java

/*
 *   Copyright 2006 The Apache Software Foundation
 *
 *   Licensed 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.upnp.tester;

import java.util.*;

import org.osgi.framework.*;
import org.osgi.service.upnp.*;

/**
 * @author Stefano "Kismet" Lenzi 
 * @author Francesco Furfari 
 * 
 */
public class UPnPSubscriber {
	private BundleContext context;
	private UPnPEventListener listener;
	private HashMap hash;
	
	private class Subscription implements UPnPEventListener{
	    ServiceRegistration registration;
	    
	    Subscription(String keys){
	 		try {
				Filter filter = context.createFilter(keys);
				Properties props = new Properties();
				props.put(UPnPEventListener.UPNP_FILTER, filter);
				registration = context.registerService(UPnPEventListener.class.getName(), this, props);
			}catch (Exception ex){
				System.out.println(ex);
			}
	    }
	    
	    public void unsubscribe(){
			registration.unregister();
	    }
	    
        public void notifyUPnPEvent(String arg0, String arg1, Dictionary arg2) {
            listener.notifyUPnPEvent( arg0,  arg1,  arg2);
        }
	}
	
	
	public UPnPSubscriber(BundleContext context,UPnPEventListener listener){
		this.context = context;
		this.listener = listener;
		hash = new HashMap();
	}
	
	public void subscribe(String deviceId, String serviceId){
		String keys = "(&(" + UPnPDevice.ID + "="+ deviceId + ")(" + UPnPService.ID + "=" + serviceId + "))";
		if (hash.get(keys) == null){
		    hash.put(keys, new Subscription(keys));
		}
	}
	
	public void unsubscribe(String deviceId, String serviceId){
		String keys = "(&(" + UPnPDevice.ID + "="+ deviceId + ")(" + UPnPService.ID + "=" + serviceId + "))";
		if (hash.containsKey(keys)) {
		    Subscription subscription = (Subscription) hash.get(keys);
		    subscription.unsubscribe();
			hash.remove(keys);
		}
	}


 	

}