Interface TaskReactorInstanceComponentProvider
-
public interface TaskReactorInstanceComponentProviderClass which is used to provide components that require Task Reactor instance name. It is designed to be used in features that have to execute some operations for all instances of Task Reactor defined in a Connector.DO NOT use it in classes where an operation needs to be executed only for a single instance and that instance name is known.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description CommandsQueuecommandsQueue(Identifier instanceSchema)Creates a new instance ofCommandsQueuefor a given Task Reactor instanceDispatcherTaskManagerdispatcherTaskManager(Identifier instanceSchema)Creates a new instance ofDispatcherTaskManagerfor a given Task Reactor instancestatic TaskReactorInstanceComponentProvidergetInstance(Session session)Creates a new instance ofTaskReactorInstanceComponentProvider
-
-
-
Method Detail
-
commandsQueue
CommandsQueue commandsQueue(Identifier instanceSchema)
Creates a new instance ofCommandsQueuefor a given Task Reactor instance- Parameters:
instanceSchema- name of Task Reactor instance- Returns:
- new instance of
CommandsQueue
-
dispatcherTaskManager
DispatcherTaskManager dispatcherTaskManager(Identifier instanceSchema)
Creates a new instance ofDispatcherTaskManagerfor a given Task Reactor instance- Parameters:
instanceSchema- name of Task Reactor instance- Returns:
- new instance of
DispatcherTaskManager
-
getInstance
static TaskReactorInstanceComponentProvider getInstance(Session session)
Creates a new instance ofTaskReactorInstanceComponentProvider- Parameters:
session- Snowpark session- Returns:
- default implementation of
TaskReactorInstanceComponentProvider
-
-