InMemoryWorkItemQueue (Test utilities for Snowflake Native SDK for Connectors - Java API Reference (2.1.0))

java.lang.Object
- com.snowflake.connectors.taskreactor.queue.InMemoryWorkItemQueue

All Implemented Interfaces:

com.snowflake.connectors.taskreactor.queue.WorkItemQueue
```
public class InMemoryWorkItemQueue
extends Object
implements com.snowflake.connectors.taskreactor.queue.WorkItemQueue
```
In memory implementation of WorkItemQueue.

Constructor Summary

Constructors
Constructor Description

InMemoryWorkItemQueue()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancelOngoingExecutions(List<String> ids)`
`void`	`clear()`	Clears this queue.
`void`	`delete(List<String> ids)`
`void`	`deleteBefore(String resourceId, Timestamp timestamp)`
`List<com.snowflake.connectors.taskreactor.queue.QueueItem>`	`fetchNotProcessedAndCancelingItems()`
`void`	`push(List<com.snowflake.connectors.taskreactor.worker.queue.WorkItem> workItems)`
`List<com.snowflake.connectors.taskreactor.queue.QueueItem>`	`store()`	Returns the list backing this queue.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
cancelOngoingExecution, delete, push

- Constructor Detail
  - InMemoryWorkItemQueue
```
public InMemoryWorkItemQueue()
```
- Method Detail
  - fetchNotProcessedAndCancelingItems
```
public List<com.snowflake.connectors.taskreactor.queue.QueueItem> fetchNotProcessedAndCancelingItems()
```
    Specified by:
    
    fetchNotProcessedAndCancelingItems in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
  - push
```
public void push(List<com.snowflake.connectors.taskreactor.worker.queue.WorkItem> workItems)
```
    Specified by:
    
    push in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
  - cancelOngoingExecutions
```
public void cancelOngoingExecutions(List<String> ids)
```
    Specified by:
    
    cancelOngoingExecutions in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
  - delete
```
public void delete(List<String> ids)
```
    Specified by:
    
    delete in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
  - deleteBefore
```
public void deleteBefore(String resourceId,
                         Timestamp timestamp)
```
    Specified by:
    
    deleteBefore in interface com.snowflake.connectors.taskreactor.queue.WorkItemQueue
  - store
```
public List<com.snowflake.connectors.taskreactor.queue.QueueItem> store()
```
    Returns the list backing this queue.
    
    Returns:
    
    list backing this queue
  - clear
```
public void clear()
```
    Clears this queue.