Class InMemoryCommandsQueueRepository
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository
-
- All Implemented Interfaces:
com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
public class InMemoryCommandsQueueRepository extends Object implements com.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
In memory implementation ofCommandsQueueRepository
.
-
-
Constructor Summary
Constructors Constructor Description InMemoryCommandsQueueRepository()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType type, Variant payload)
void
deleteById(String id)
void
deleteUnsupportedCommands()
List<com.snowflake.connectors.taskreactor.commands.queue.Command>
fetchAllSupportedOrderedBySeqNo()
-
-
-
Method Detail
-
fetchAllSupportedOrderedBySeqNo
public List<com.snowflake.connectors.taskreactor.commands.queue.Command> fetchAllSupportedOrderedBySeqNo()
- Specified by:
fetchAllSupportedOrderedBySeqNo
in interfacecom.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
-
add
public void add(com.snowflake.connectors.taskreactor.commands.queue.Command.CommandType type, Variant payload)
- Specified by:
add
in interfacecom.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
-
deleteById
public void deleteById(String id)
- Specified by:
deleteById
in interfacecom.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
-
deleteUnsupportedCommands
public void deleteUnsupportedCommands()
- Specified by:
deleteUnsupportedCommands
in interfacecom.snowflake.connectors.taskreactor.commands.queue.CommandsQueueRepository
-
-