OSGi开发之Event:事件处理[原]

osgi> ss
 
Framework is launched.
 
id	State       Bundle
0	ACTIVE      org.eclipse.osgi_3.3.1.R33x_v20070828
1	ACTIVE      org.eclipse.equinox.common_3.3.0.v20070426
2	ACTIVE      org.eclipse.equinox.log_1.0.100.v20070226
3	ACTIVE      org.eclipse.equinox.ds_1.0.0.qualifier
4	ACTIVE      org.eclipse.equinox.registry_3.3.1.R33x_v20070802
5	ACTIVE      org.eclipse.osgi.services_3.1.200.v20070605
6	ACTIVE      org.eclipse.equinox.event_1.0.100.v20070516
7	ACTIVE      org.eclipse.osgi.util_3.1.200.v20070605
 
osgi>

package com.demo.eventpublisher;
 
import org.osgi.framework.BundleContext;
import org.osgi.service.log.LogService;
import org.osgi.util.tracker.ServiceTracker;
 
/**
 * Utility class with static methods for logging to LogService, if available 
 * 
 * @version $Revision: 1.1 $
 */
public class Log {
 
	static private ServiceTracker logTracker;
 
	private Log() {
	}
 
	public static void init(BundleContext bc) {
		logTracker = new ServiceTracker(bc, LogService.class.getName(), null);
		logTracker.open();
	}
 
	static void dispose() {
		if (logTracker != null) {
			logTracker.close();
		}
		logTracker = null;
	}
 
	public static void log(int level, String message) {
		log(level, message, null);、
	}
 
	public static void log(int level, String message, Throwable e) {
		LogService logService = (LogService) logTracker.getService();
		if (logService != null) {
			logService.log(level, message, e);
		}
	}
 
	public static void info(String message)
	{
		info(message, null);
	}
 
	public static void info(String message, Throwable e)
	{
		log(LogService.LOG_INFO, message, e);
	}
}

package com.demo.eventpublisher;
 
import java.util.Calendar;
import java.util.Hashtable;
 
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.service.event.Event;
import org.osgi.service.event.EventAdmin;
import org.osgi.util.tracker.ServiceTracker;
 
public class TimerEvent extends Thread implements BundleActivator {
    Hashtable time = new Hashtable();
    ServiceTracker tracker;
 
    public TimerEvent() {
        super("TimerEvent");
    }
 
    public void start(BundleContext context) {
        Log.init(context);
        tracker = new ServiceTracker(context, EventAdmin.class.getName(), null);
        tracker.open();
        start();
    }
 
    public void stop(BundleContext context) {
        interrupt();
        tracker.close();
        Log.dispose();
    }
 
    public void run() {
        while (!Thread.interrupted())
            try {
                Log.info("Rasie Event");
                Calendar c = Calendar.getInstance();
                set(c, Calendar.MINUTE, "minutes");
                set(c, Calendar.HOUR, "hours");
                set(c, Calendar.DAY_OF_MONTH, "day");
                set(c, Calendar.MONTH, "month");
                set(c, Calendar.YEAR, "year");
                EventAdmin ea = (EventAdmin) tracker.getService();
                if (ea != null)
                    ea.sendEvent(new Event("com/demo/timer", time));
                Thread.sleep(60000 - c.get(Calendar.SECOND) * 1000);
            }
            catch (InterruptedException e) {
                // 忽略
            }
    }
 
    void set(Calendar c, int field, String key) {
        time.put(key, new Integer(c.get(field)));
    }
}

Manifest-Version: 1.0
Bundle-ManifestVersion: 2
Bundle-Name: EventPublisher Plug-in
Bundle-SymbolicName: EventPublisher
Bundle-Version: 1.0.0
Bundle-Activator: com.demo.eventpublisher.TimerEvent
Import-Package: org.osgi.framework;version="1.3.0",
 org.osgi.service.event;version="1.1.0",
 org.osgi.service.log;version="1.3.0",
 org.osgi.util.tracker;version="1.3.2"
 

package com.demo.eventhandler;
 
import java.util.Dictionary;
import java.util.Hashtable;
 
import org.osgi.framework.BundleContext;
import org.osgi.service.event.Event;
import org.osgi.service.event.EventConstants;
import org.osgi.service.event.EventHandler;
 
import com.demo.internal.Log;
 
public class CustomEventHandler implements EventHandler
{
    public final static String [] topics = new String[] { 
//        "org/osgi/service/log/LogEntry/LOG_INFO", 
//        "org/osgi/service/log/LogEntry/LOG_WARNING",
//        "org/osgi/framework/ServiceEvent/REGISTERED",
//        "org/osgi/framework/ServiceEvent/MODIFIED",
//        "org/osgi/framework/ServiceEvent/UNREGISTERING",
//        "org/osgi/framework/FrameworkEvent/STARTED",
//        "org/osgi/service/log/LogEntry/LOG_ERROR",
        "com/demo/timer"}; 
    
    public void registry(BundleContext context)
    {
        Dictionary d = new Hashtable(); 
        d.put(EventConstants.EVENT_TOPIC, topics ); 
 
        context.registerService( EventHandler.class.getName(), this, d ); 
    }
    public void handleEvent(Event event)
    {
        if ("com/acme/timer".equals(event.getTopic()))
        {
            Log.info("Received event, EventTopic " + event.getTopic() + " " + event.getProperty("year") + "-" + event.getProperty("month") + "-" + event.getProperty("day"));
        }
        else
        {
            Log.info("Received event, EventTopic " + event.getTopic());
        }  
    }
}

package com.demo.internal;
 
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
 
import com.demo.eventhandler.CustomEventHandler;
 
 
public class Activator implements BundleActivator
{
    public void start(BundleContext context) throws Exception
    {
        Log.init(context);
        CustomEventHandler eventhandler = new CustomEventHandler();
        eventhandler.registry(context);
    }
 
    public void stop(BundleContext context) throws Exception
    {
        Log.dispose();
    }
}