org.codice.ddf.ui.searchui.query.controller

Class NotificationController

java.lang.Object

org.codice.ddf.ui.searchui.query.controller.AbstractEventController

org.codice.ddf.ui.searchui.query.controller.NotificationController

All Implemented Interfaces:

org.osgi.service.event.EventHandler

@Service
public class NotificationController
extends AbstractEventController

The NotificationController handles the processing and routing of notifications.

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	NOTIFICATION_TOPIC_DOWNLOADS_COMETD

Fields inherited from class org.codice.ddf.ui.searchui.query.controller.AbstractEventController

EVENT_TOPIC_CANCEL

Constructor Summary

Constructors

Constructor and Description
NotificationController(PersistentStore persistentStore, org.osgi.framework.BundleContext bundleContext, org.osgi.service.event.EventAdmin eventAdmin)

Method Summary

Modifier and Type	Method and Description
void	deletePersistentNotification(org.cometd.bayeux.server.ServerSession serverSession, org.cometd.bayeux.server.ServerMessage serverMessage)
String	getControllerRootTopic() Obtains the root topic of the controller that should be used when registering the eventhandler.
List<Map<String,Object>>	getNotificationsForUser(String userId)
void	getPersistedNotifications(org.cometd.bayeux.server.ServerSession remote, org.cometd.bayeux.Message message)
void	handleEvent(org.osgi.service.event.Event event) Implementation of EventHandler.handleEvent(Event) that receives notifications published on the Notification.NOTIFICATION_TOPIC_ROOT topic from the OSGi eventing framework and forwards them to their intended recipients.

Methods inherited from class org.codice.ddf.ui.searchui.query.controller.AbstractEventController

adminCancelDownload, deregisterUserSession, getSessionById, getSessionBySessionId, getSessionByUserId, getUserId, queuePersistedMessages, registerUserSession

Methods inherited from class java.lang.Object

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

Field Detail

NOTIFICATION_TOPIC_DOWNLOADS_COMETD

protected static final String NOTIFICATION_TOPIC_DOWNLOADS_COMETD

See Also:

Constant Field Values

Constructor Detail

NotificationController

public NotificationController(PersistentStore persistentStore,
                              org.osgi.framework.BundleContext bundleContext,
                              org.osgi.service.event.EventAdmin eventAdmin)

Method Detail

handleEvent

public void handleEvent(org.osgi.service.event.Event event)
                 throws IllegalArgumentException

Implementation of EventHandler.handleEvent(Event) that receives notifications published on the Notification.NOTIFICATION_TOPIC_ROOT topic from the OSGi eventing framework and forwards them to their intended recipients.

Throws:

IllegalArgumentException - when any of the following required properties are either missing from the Event or contain empty values:

• Notification.NOTIFICATION_KEY_APPLICATION
• Notification.NOTIFICATION_KEY_MESSAGE
• Notification.NOTIFICATION_KEY_TIMESTAMPNotification.NOTIFICATION_KEY_TITLE
• Notification.NOTIFICATION_KEY_USER_ID

getControllerRootTopic

public String getControllerRootTopic()

Description copied from class: AbstractEventController

Obtains the root topic of the controller that should be used when registering the eventhandler.

Specified by:

getControllerRootTopic in class AbstractEventController

Returns:

String representation of a root topic.

getPersistedNotifications

@Listener(value="/ddf/notifications")
public void getPersistedNotifications(org.cometd.bayeux.server.ServerSession remote,
                                                                            org.cometd.bayeux.Message message)

deletePersistentNotification

@Listener(value="/notification/action")
public void deletePersistentNotification(org.cometd.bayeux.server.ServerSession serverSession,
                                                                                 org.cometd.bayeux.server.ServerMessage serverMessage)

getNotificationsForUser

public List<Map<String,Object>> getNotificationsForUser(String userId)