| Modifier and Type | Method and Description |
|---|---|
boolean |
NotificationFeedManager.createFeed(co.cask.cdap.proto.notification.NotificationFeedInfo feed)
Create a notification feed.
|
void |
NotificationFeedManager.deleteFeed(co.cask.cdap.proto.id.NotificationFeedId feed)
Deletes the
feed from the manager store. |
co.cask.cdap.proto.notification.NotificationFeedInfo |
NotificationFeedManager.getFeed(co.cask.cdap.proto.id.NotificationFeedId feed)
Get a
NotificationFeedId based on the feed.getId() method of the feed argument. |
List<co.cask.cdap.proto.notification.NotificationFeedInfo> |
NotificationFeedManager.listFeeds(co.cask.cdap.proto.id.NamespaceId namespace)
List all the
NotificationFeedInfos present in the manager store for a namespace. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RemoteNotificationFeedManager.createFeed(co.cask.cdap.proto.notification.NotificationFeedInfo feed) |
void |
RemoteNotificationFeedManager.deleteFeed(co.cask.cdap.proto.id.NotificationFeedId feed) |
co.cask.cdap.proto.notification.NotificationFeedInfo |
RemoteNotificationFeedManager.getFeed(co.cask.cdap.proto.id.NotificationFeedId feed) |
List<co.cask.cdap.proto.notification.NotificationFeedInfo> |
RemoteNotificationFeedManager.listFeeds(co.cask.cdap.proto.id.NamespaceId namespace) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
NoOpNotificationFeedManager.createFeed(co.cask.cdap.proto.notification.NotificationFeedInfo feed) |
void |
NoOpNotificationFeedManager.deleteFeed(co.cask.cdap.proto.id.NotificationFeedId feed) |
List<co.cask.cdap.proto.notification.NotificationFeedInfo> |
NoOpNotificationFeedManager.listFeeds(co.cask.cdap.proto.id.NamespaceId namespace) |
| Modifier and Type | Method and Description |
|---|---|
<N> org.apache.twill.common.Cancellable |
NotificationService.subscribe(co.cask.cdap.proto.id.NotificationFeedId feed,
NotificationHandler<N> handler)
Subscribe to the notification received on the
feed, and handle the notifications with the handler. |
<N> org.apache.twill.common.Cancellable |
NotificationService.subscribe(co.cask.cdap.proto.id.NotificationFeedId feed,
NotificationHandler<N> handler,
Executor executor)
Subscribe to the notification received on the
feed, and handle the notifications with the handler. |
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.