Package eu.dnetlib.broker.events.output

Class AbstractNotificationDispatcher<T>

java.lang.Object

eu.dnetlib.broker.events.output.AbstractNotificationDispatcher<T>

All Implemented Interfaces:

NotificationDispatcher, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

AlertRemoteApiDispatcher, EmailDispatcher, MockDispatcher

public abstract class AbstractNotificationDispatcher<T>
extends Object
implements NotificationDispatcher, org.springframework.beans.factory.BeanNameAware, Runnable

Constructor Summary

Constructors

Constructor	Description
AbstractNotificationDispatcher()

Method Summary

Modifier and Type	Method	Description
long	count()
long	countErrors()
String	getDispatcherName()
void	init()
String	lastError()
protected abstract void	performAction(T message)
protected abstract T	prepareAction(Subscription subscription, Event... events)
protected abstract T	prepareAction(Subscription subscription, Map<String,Object> params)
void	resetCount()
void	run()
void	sendNotification(Subscription subscription, Event... events)
void	sendNotification(Subscription subscription, Map<String,Object> params)
void	setBeanName(String name)
void	setDispatcherName(String dispatcherName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.dnetlib.broker.events.output.NotificationDispatcher

getMode

Constructor Details

AbstractNotificationDispatcher

public AbstractNotificationDispatcher()

Method Details

init

@PostConstruct
public void init()

run

public void run()

Specified by:

run in interface Runnable

sendNotification

public void sendNotification(Subscription subscription,
 Event... events)

Specified by:

sendNotification in interface NotificationDispatcher

sendNotification

public void sendNotification(Subscription subscription,
 Map<String,Object> params)

Specified by:

sendNotification in interface NotificationDispatcher

prepareAction

protected abstract T prepareAction(Subscription subscription,
 Map<String,Object> params)
                            throws Exception

Throws:

Exception

prepareAction

protected abstract T prepareAction(Subscription subscription,
 Event... events)
                            throws Exception

Throws:

Exception

performAction

protected abstract void performAction(T message)
                               throws Exception

Throws:

Exception

getDispatcherName

public String getDispatcherName()

Specified by:

getDispatcherName in interface NotificationDispatcher

setDispatcherName

public void setDispatcherName(String dispatcherName)

count

public long count()

Specified by:

count in interface NotificationDispatcher

countErrors

public long countErrors()

Specified by:

countErrors in interface NotificationDispatcher

lastError

public String lastError()

Specified by:

lastError in interface NotificationDispatcher

resetCount

public void resetCount()

Specified by:

resetCount in interface NotificationDispatcher

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware