org.apache.asterix.metadata.feeds

Class FeedConnectionManager

java.lang.Object

org.apache.asterix.metadata.feeds.FeedConnectionManager

All Implemented Interfaces:

IFeedConnectionManager

public class FeedConnectionManager
extends Object
implements IFeedConnectionManager

An implementation of the IFeedManager interface. Provider necessary central repository for registering/retrieving artifacts/services associated with a feed.

Constructor Summary

Constructors

Constructor and Description
FeedConnectionManager(String nodeId)

Method Summary

Methods

Modifier and Type	Method and Description
void	deregisterFeed(FeedConnectionId feedId)
void	deRegisterFeedRuntime(FeedConnectionId connectionId, FeedRuntimeId feedRuntimeId)
FeedRuntime	getFeedRuntime(FeedConnectionId connectionId, FeedRuntimeId feedRuntimeId)
FeedRuntimeManager	getFeedRuntimeManager(FeedConnectionId feedId)
List<FeedRuntimeId>	getRegisteredRuntimes()
void	registerFeedRuntime(FeedConnectionId connectionId, FeedRuntime feedRuntime)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedConnectionManager

public FeedConnectionManager(String nodeId)

Method Detail

getFeedRuntimeManager

public FeedRuntimeManager getFeedRuntimeManager(FeedConnectionId feedId)

Specified by:

getFeedRuntimeManager in interface IFeedConnectionManager

deregisterFeed

public void deregisterFeed(FeedConnectionId feedId)

Specified by:

deregisterFeed in interface IFeedConnectionManager

registerFeedRuntime

public void registerFeedRuntime(FeedConnectionId connectionId,
                       FeedRuntime feedRuntime)
                         throws Exception

Specified by:

registerFeedRuntime in interface IFeedConnectionManager

Throws:

Exception

deRegisterFeedRuntime

public void deRegisterFeedRuntime(FeedConnectionId connectionId,
                         FeedRuntimeId feedRuntimeId)

Specified by:

deRegisterFeedRuntime in interface IFeedConnectionManager

getFeedRuntime

public FeedRuntime getFeedRuntime(FeedConnectionId connectionId,
                         FeedRuntimeId feedRuntimeId)

Specified by:

getFeedRuntime in interface IFeedConnectionManager

toString

public String toString()

Overrides:

toString in class Object

getRegisteredRuntimes

public List<FeedRuntimeId> getRegisteredRuntimes()

Specified by:

getRegisteredRuntimes in interface IFeedConnectionManager