co.cask.cdap.notifications.service.inmemory

Class InMemoryNotificationService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.common.service.UncaughtExceptionIdleService

co.cask.cdap.notifications.service.AbstractNotificationService

co.cask.cdap.notifications.service.inmemory.InMemoryNotificationService

All Implemented Interfaces:

NotificationService, com.google.common.util.concurrent.Service

public class InMemoryNotificationService
extends AbstractNotificationService

In-memory Notification service that pushes notifications to subscribers.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
InMemoryNotificationService(DatasetFramework dsFramework, TransactionSystemClientService transactionSystemClient, NotificationFeedManager feedManager)

Method Summary

Methods

Modifier and Type	Method and Description
<N> com.google.common.util.concurrent.ListenableFuture<N>	publish(Id.NotificationFeed feed, N notification, Type notificationType)
protected void	shutDown()
protected void	startUp()

Methods inherited from class co.cask.cdap.notifications.service.AbstractNotificationService

createGson, getUncaughtExceptionLogger, notificationReceived, publish, subscribe, subscribe

Methods inherited from class co.cask.cdap.common.service.UncaughtExceptionIdleService

executor, newHandler

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, isRunning, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

InMemoryNotificationService

@Inject
public InMemoryNotificationService(DatasetFramework dsFramework,
                                  TransactionSystemClientService transactionSystemClient,
                                  NotificationFeedManager feedManager)

Method Detail

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractNotificationService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class AbstractNotificationService

Throws:

Exception

publish

public <N> com.google.common.util.concurrent.ListenableFuture<N> publish(Id.NotificationFeed feed,
                                                                N notification,
                                                                Type notificationType)
                                                              throws NotificationException

Throws:

NotificationException