com.neurosys.q.notification.service

Class AbstractTokenNotificationListener<T extends Token<T>,N>

java.lang.Object

com.neurosys.q.notification.events.SynchronousTokenChangeListener<T,TokenEvent<T>>

com.neurosys.q.notification.events.SynchronousTokenChangeEventSupplierBackedListener<T,MessageTokenEvent<T>>

com.neurosys.q.notification.service.AbstractTokenNotificationListener<T,N>

Type Parameters:

T - as Token type

N - as notification message type like email, SMS, Voice etc.

All Implemented Interfaces:

ChangeListener<TokenEvent<T>>, Serializable, EventListener

public abstract class AbstractTokenNotificationListener<T extends Token<T>,N>
extends SynchronousTokenChangeEventSupplierBackedListener<T,MessageTokenEvent<T>>

Handle all Notification (to Phone SMS) related stuff.

Author:

Arjun Dhar

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractNotificationHelper<T>	notificationHelper

Constructor Summary

Constructors

Constructor and Description
AbstractTokenNotificationListener()

Method Summary

Modifier and Type	Method and Description
protected abstract List<N>	createNotifications(MessageTokenEvent<T> event, String timeStampId) Create Notifications N and add to List of final Notifications to send.
protected String	deriveMessageId(MessageTokenEvent<T> e, T token, String timeStampId)
protected abstract void	dispatch(List<N> messages) Raw dispatch of messages without Feedback processing
protected void	dispatch(List<N> messages, List<MessageTokenEvent<T>> events, TokenEvent<T> parentEvent)
AbstractNotificationHelper<T>	getNotificationHelper()
protected void	onError(MessageTokenEvent<T> event, T token, Throwable err) On error while sending notification
protected void	onEventSupplierGenEvents(Supplier<List<MessageTokenEvent<T>>> eventsSupplier, TokenEvent<T> parentEvent)
protected void	onSuccess(MessageTokenEvent<T> event, T token) On notification successfully sent
protected void	preProcessNotificationEvents(List<MessageTokenEvent<T>> events) Opportunity to update tokens with things like missing contact Consumer data etc.
void	setNotificationHelper(AbstractNotificationHelper<T> notificationHelper)
protected abstract T	tokenFromPayloadException(PayLoadException err) When calling dispatch(List) a PartialTransactionException with PartialTransactionException.getFailed() is a List of PayLoadException.

Methods inherited from class com.neurosys.q.notification.events.SynchronousTokenChangeEventSupplierBackedListener

getTokenEventSupplier, onSynchChange, setTokenEventSupplier

Methods inherited from class com.neurosys.q.notification.events.SynchronousTokenChangeListener

onChange

Methods inherited from class java.lang.Object

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

Field Detail

notificationHelper

protected AbstractNotificationHelper<T extends Token<T>> notificationHelper

Constructor Detail

AbstractTokenNotificationListener

public AbstractTokenNotificationListener()

Method Detail

preProcessNotificationEvents

protected void preProcessNotificationEvents(List<MessageTokenEvent<T>> events)

Opportunity to update tokens with things like missing contact Consumer data etc. in bulk.

Parameters:

events - as List of MessageTokenEvent

onEventSupplierGenEvents

protected void onEventSupplierGenEvents(Supplier<List<MessageTokenEvent<T>>> eventsSupplier,
                                        TokenEvent<T> parentEvent)

Specified by:

onEventSupplierGenEvents in class SynchronousTokenChangeEventSupplierBackedListener<T extends Token<T>,MessageTokenEvent<T extends Token<T>>>

createNotifications

protected abstract List<N> createNotifications(MessageTokenEvent<T> event,
                                               String timeStampId)

Create Notifications N and add to List of final Notifications to send.

Parameters:

notifications - as List of type

event - as MessageTokenEvent

timeStampId - as String for batch of notifications

Returns:

List of messages/notification generated out of the MessageTokenEvent

tokenFromPayloadException

protected abstract T tokenFromPayloadException(PayLoadException err)

When calling dispatch(List) a PartialTransactionException with PartialTransactionException.getFailed() is a List of PayLoadException. This payload object is defined by the overriding class and should contain a reference to the Token, hence it knows best how to extract the Token.

Parameters:

err - as PayLoadException

Returns:

Token type

dispatch

protected void dispatch(List<N> messages,
                        List<MessageTokenEvent<T>> events,
                        TokenEvent<T> parentEvent)

onSuccess

protected void onSuccess(MessageTokenEvent<T> event,
                         T token)

On notification successfully sent

Parameters:

event - as MessageTokenEvent

token - as Token type

onError

protected void onError(MessageTokenEvent<T> event,
                       T token,
                       Throwable err)

On error while sending notification

Parameters:

event - as MessageTokenEvent

token - as Token type

err - as Throwable

dispatch

protected abstract void dispatch(List<N> messages)
                          throws PartialTransactionException,
                                 Exception

Raw dispatch of messages without Feedback processing

Parameters:

messages -

Throws:

PartialTransactionException

Exception

deriveMessageId

protected String deriveMessageId(MessageTokenEvent<T> e,
                                 T token,
                                 String timeStampId)

getNotificationHelper

public AbstractNotificationHelper<T> getNotificationHelper()

setNotificationHelper

public void setNotificationHelper(AbstractNotificationHelper<T> notificationHelper)