co.cask.cdap.notifications.feeds.client

Class RemoteNotificationFeedManager

java.lang.Object

co.cask.cdap.notifications.feeds.client.RemoteNotificationFeedManager

All Implemented Interfaces:

NotificationFeedManager

public class RemoteNotificationFeedManager
extends Object
implements NotificationFeedManager

Implementation of the NotificationFeedManager that connects to a remote feed manager service through internal RESTful APIs.

Constructor Summary

Constructors

Constructor and Description
RemoteNotificationFeedManager(DiscoveryServiceClient discoveryClient)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	createFeed(co.cask.cdap.proto.Id.NotificationFeed feed) Create a notification feed.
void	deleteFeed(co.cask.cdap.proto.Id.NotificationFeed feed) Deletes the feed from the manager store.
co.cask.cdap.proto.Id.NotificationFeed	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>	listFeeds(co.cask.cdap.proto.Id.Namespace namespace) List all the Id.NotificationFeeds present in the manager store for a namespace.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteNotificationFeedManager

@Inject
public RemoteNotificationFeedManager(DiscoveryServiceClient discoveryClient)

Method Detail

createFeed

public boolean createFeed(co.cask.cdap.proto.Id.NotificationFeed feed)
                   throws NotificationFeedException

Description copied from interface: NotificationFeedManager

Create a notification feed.

Specified by:

createFeed in interface NotificationFeedManager

Parameters:

feed - the feed to create

Returns:

true if the feed was created successfully; false if the feed already exists

Throws:

NotificationFeedException - if the feed has an incorrect structure; for example, if it is missing a name, a namespace or a category

deleteFeed

public void deleteFeed(co.cask.cdap.proto.Id.NotificationFeed feed)
                throws NotificationFeedNotFoundException,
                       NotificationFeedException

Description copied from interface: NotificationFeedManager

Deletes the feed from the manager store. To determine if the feed exists, the Id.NotificationFeed#getFeedId method is used.

Specified by:

deleteFeed in interface NotificationFeedManager

Parameters:

feed - the Id.NotificationFeed to delete

Throws:

NotificationFeedNotFoundException - if the feed does not exist

NotificationFeedException - in case of unforeseen error

getFeed

public co.cask.cdap.proto.Id.NotificationFeed getFeed(co.cask.cdap.proto.Id.NotificationFeed feed)
                                               throws NotificationFeedNotFoundException,
                                                      NotificationFeedException

Description copied from interface: NotificationFeedManager

Get a Id.NotificationFeed based on the feed.getId() method of the feed argument.

Specified by:

getFeed in interface NotificationFeedManager

Parameters:

feed - feed containing the feed Id of the feed to retrieve

Returns:

Id.NotificationFeed of the feed which ID is the same as feed

Throws:

NotificationFeedNotFoundException - if the feed does not exist

NotificationFeedException - in case of unforeseen error

listFeeds

public List<co.cask.cdap.proto.Id.NotificationFeed> listFeeds(co.cask.cdap.proto.Id.Namespace namespace)
                                                       throws NotificationFeedException

Description copied from interface: NotificationFeedManager

List all the Id.NotificationFeeds present in the manager store for a namespace.

Specified by:

listFeeds in interface NotificationFeedManager

Parameters:

namespace - Id of the namespace to list feeds for

Returns:

all the Id.NotificationFeeds present in the manager store

Throws:

NotificationFeedException - in case of unforeseen error