co.cask.cdap.notifications.service.kafka

Class KafkaNotificationService

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.kafka.KafkaNotificationService

All Implemented Interfaces:

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

public class KafkaNotificationService
extends AbstractNotificationService

Kafka implementation of the NotificationService.

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

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()
<N> Cancellable	subscribe(Id.NotificationFeed feed, NotificationHandler<N> handler, Executor executor)

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

createGson, getUncaughtExceptionLogger, notificationReceived, publish, 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

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

subscribe

public <N> Cancellable subscribe(Id.NotificationFeed feed,
                        NotificationHandler<N> handler,
                        Executor executor)
                      throws NotificationFeedNotFoundException,
                             NotificationFeedException

Specified by:

subscribe in interface NotificationService

Overrides:

subscribe in class AbstractNotificationService

Throws:

NotificationFeedNotFoundException

NotificationFeedException