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