org.ops4j.pax.radman.service.event.repeater.broadcaster.internal
Class EventBroadcasterImpl<E>

java.lang.Object
  org.ops4j.pax.radman.service.event.repeater.broadcaster.internal.EventBroadcasterImpl<E>

All Implemented Interfaces:

EventBroadcaster, EventQueueListener<E>

@ThreadSafe
public class EventBroadcasterImpl<E>
extends java.lang.Object
implements EventQueueListener<E>, EventBroadcaster

Responsibilities

• reads from an EventQueue
• sends the dequeued element to a remote Gateway

Each EventBroadcasterImpl will fire off a separate thread to perform the dequeuing & submission to the remote Gateway. To improve the throughput of events processed, instantiate multiple EventBroadcasterImpl via EventBroadcasterManagedServiceFactory.

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.broadcaster.internal.EventBroadcasterImpl.Decision	formulateDecisionUsing(java.util.Dictionary<java.lang.String,java.lang.Object> serviceProperties)
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.broadcaster.internal.EventBroadcasterImpl.Decision formulateDecisionUsing(java.util.Dictionary<java.lang.String,java.lang.Object> serviceProperties)

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>