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 ofCommandsProcessorused by the Task Reactor.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidprocessCommands()Fetches all pending, valid commands from the commands queue and executes them using properCommandExecutordefined by the implementation of theExecutorStrategies.
-
-
-
Method Detail
-
processCommands
public void processCommands()
Fetches all pending, valid commands from the commands queue and executes them using properCommandExecutordefined by the implementation of theExecutorStrategies. Deletes all unsupported commands from the queue at the end.- Specified by:
processCommandsin interfaceCommandsProcessor
-
-