org.ops4j.pax.radman.service.event.repeater.consumer.internal
Class EventSubscriber<E>

java.lang.Object
  org.ops4j.pax.radman.service.event.repeater.consumer.internal.EventSubscriber<E>

All Implemented Interfaces:

EventQueueListener<E>, org.osgi.service.event.EventHandler

@ThreadSafe
public class EventSubscriber<E>
extends java.lang.Object
implements org.osgi.service.event.EventHandler, EventQueueListener<E>

Notes:

• Do not log to pax-logging as that may cause an event to be generated!

Since:

0.1.0

Author:

Gavin Bong

Method Summary

void	addService(EventQueue<E> service, org.osgi.framework.ServiceReference reference)
org.ops4j.pax.radman.service.event.repeater.consumer.internal.EventSubscriber.Decision	formulateDecisionUsing(java.util.Dictionary<java.lang.String,java.lang.Object> serviceProperties) TODO: What happens when SERVICE_PID is changed ?
void	handleEvent(org.osgi.service.event.Event event)
void	removeService(EventQueue<E> service, org.osgi.framework.ServiceReference reference)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

formulateDecisionUsing

public final org.ops4j.pax.radman.service.event.repeater.consumer.internal.EventSubscriber.Decision formulateDecisionUsing(java.util.Dictionary<java.lang.String,java.lang.Object> serviceProperties)

TODO:

• What happens when SERVICE_PID is changed ?

Parameters:

serviceProperties - precondition is that this is valid & canonicalized

Returns:

the next Decision to take

handleEvent

public void handleEvent(org.osgi.service.event.Event event)

Specified by:

handleEvent in interface org.osgi.service.event.EventHandler

addService

public void addService(EventQueue<E> service,
                       org.osgi.framework.ServiceReference reference)

Specified by:

addService in interface EventQueueListener<E>

removeService

public void removeService(EventQueue<E> service,
                          org.osgi.framework.ServiceReference reference)

Specified by:

removeService in interface EventQueueListener<E>