Package org.apache.nifi.util

Class MockSessionFactory

java.lang.Object

org.apache.nifi.util.MockSessionFactory

All Implemented Interfaces:

org.apache.nifi.processor.ProcessSessionFactory

public class MockSessionFactory
extends Object
implements org.apache.nifi.processor.ProcessSessionFactory

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	allowRecursiveReads
private final boolean	allowSynchronousSessionCommits
private final Set<MockProcessSession>	createdSessions
private final boolean	enforceReadStreamsClosed
private final org.apache.nifi.processor.Processor	processor
private final SharedSessionState	sharedState
private final org.apache.nifi.components.state.StateManager	stateManager

Constructor Summary

Constructors

Constructor	Description
MockSessionFactory(SharedSessionState sharedState, org.apache.nifi.processor.Processor processor, boolean enforceReadStreamsClosed, org.apache.nifi.components.state.StateManager stateManager, boolean allowSynchronousSessionCommits, boolean allowRecursiveReads)

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.processor.ProcessSession	createSession()
Set<MockProcessSession>	getCreatedSessions()

Methods inherited from class java.lang.Object

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

Field Details

processor

private final org.apache.nifi.processor.Processor processor

sharedState

private final SharedSessionState sharedState

createdSessions

private final Set<MockProcessSession> createdSessions

enforceReadStreamsClosed

private final boolean enforceReadStreamsClosed

stateManager

private final org.apache.nifi.components.state.StateManager stateManager

allowSynchronousSessionCommits

private final boolean allowSynchronousSessionCommits

allowRecursiveReads

private final boolean allowRecursiveReads

Constructor Details

MockSessionFactory

MockSessionFactory(SharedSessionState sharedState,
 org.apache.nifi.processor.Processor processor,
 boolean enforceReadStreamsClosed,
 org.apache.nifi.components.state.StateManager stateManager,
 boolean allowSynchronousSessionCommits,
 boolean allowRecursiveReads)

Method Details

createSession

public org.apache.nifi.processor.ProcessSession createSession()

Specified by:

createSession in interface org.apache.nifi.processor.ProcessSessionFactory

getCreatedSessions

public Set<MockProcessSession> getCreatedSessions()