org.ops4j.pax.radman.gateway.event.internal
Class EventServerImpl<E>

java.lang.Object
  org.ops4j.pax.radman.gateway.event.internal.EventServerImpl<E>

Type Parameters:

E - the type of elements which will be written to the queue

All Implemented Interfaces:

EventQueueListener<E>, EventServer<E>

public class EventServerImpl<E>
extends java.lang.Object
implements EventServer<E>, EventQueueListener<E>

Configurable options:

• list of blacklisted IP addresses (OPTIONAL)
• service pid of a Queue (intermediate storage for EventMessage before the persistence stage)
• TCP port for socket acceptor

Since:

0.1.0

Author:

Gavin Bong

Method Summary

void	addService(EventQueue<E> service, org.osgi.framework.ServiceReference reference)
boolean	offer(E message)
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

offer

public boolean offer(E message)

Specified by:

offer in interface EventServer<E>

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>