Package org.apache.nifi.util

Class MockFlowFileQueue

java.lang.Object

org.apache.nifi.util.MockFlowFileQueue

public class MockFlowFileQueue
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final BlockingQueue<MockFlowFile>	queue
private final Lock	readLock
private final ReadWriteLock	rwLock
private final Lock	writeLock

Constructor Summary

Constructors

Constructor	Description
MockFlowFileQueue()

Method Summary

Modifier and Type	Method	Description
void	addAll(Collection<MockFlowFile> flowFiles)
boolean	isEmpty()
void	offer(MockFlowFile flowFile)
MockFlowFile	poll()
org.apache.nifi.controller.queue.QueueSize	size()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

queue

private final BlockingQueue<MockFlowFile> queue

rwLock

private final ReadWriteLock rwLock

readLock

private final Lock readLock

writeLock

private final Lock writeLock

Constructor Details

MockFlowFileQueue

public MockFlowFileQueue()

Method Details

offer

public void offer(MockFlowFile flowFile)

poll

public MockFlowFile poll()

addAll

public void addAll(Collection<MockFlowFile> flowFiles)

size

public org.apache.nifi.controller.queue.QueueSize size()

isEmpty

public boolean isEmpty()