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

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

Type Parameters:

E - the type of elements read from the queue

All Implemented Interfaces:

EventPersistor<E>, EventQueueListener<E>

@ThreadSafe
public class EventPersistorImpl<E>
extends java.lang.Object
implements EventPersistor<E>, EventQueueListener<E>

Configurable options:

• service pid of a Queue (intermediate storage for EventMessage before the persistence stage)
• JPA persistence unit name

Since:

0.1.0

Author:

Gavin Bong

See Also:

EventPersistorManagedServiceFactory

Method Summary

void	addService(EventQueue<E> service, org.osgi.framework.ServiceReference reference)
org.ops4j.pax.radman.gateway.event.internal.EventPersistorImpl.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.gateway.event.internal.EventPersistorImpl.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>