Interface TaskReactorInstanceComponentProvider
-
public interface TaskReactorInstanceComponentProvider
Class 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 CommandsQueueRepository
commandsQueueRepository(Identifier instanceSchema)
Creates a new instance ofCommandsQueueRepository
for a given Task Reactor instanceDispatcherTaskManager
dispatcherTaskManager(Identifier instanceSchema)
Creates a new instance ofDispatcherTaskManager
for a given Task Reactor instancestatic TaskReactorInstanceComponentProvider
getInstance(Session session)
Creates a new instance ofTaskReactorInstanceComponentProvider
-
-
-
Method Detail
-
commandsQueueRepository
CommandsQueueRepository commandsQueueRepository(Identifier instanceSchema)
Creates a new instance ofCommandsQueueRepository
for a given Task Reactor instance- Parameters:
instanceSchema
- name of Task Reactor instance- Returns:
- new instance of
CommandsQueueRepository
-
dispatcherTaskManager
DispatcherTaskManager dispatcherTaskManager(Identifier instanceSchema)
Creates a new instance ofDispatcherTaskManager
for 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
-
-