Class DefaultCommandsProcessor
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.commands.processor.DefaultCommandsProcessor
-
- All Implemented Interfaces:
CommandsProcessor
public class DefaultCommandsProcessor extends Object implements CommandsProcessor
Default implementation ofCommandsProcessor
used by the Task Reactor.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
processCommands()
Fetches all pending, valid commands from the commands queue and executes them using properCommandExecutor
defined by the implementation of theExecutorStrategies
.
-
-
-
Method Detail
-
processCommands
public void processCommands()
Fetches all pending, valid commands from the commands queue and executes them using properCommandExecutor
defined by the implementation of theExecutorStrategies
. Deletes all unsupported commands from the queue at the end.- Specified by:
processCommands
in interfaceCommandsProcessor
-
-