nl.nn.adapterframework.stream

Class ThreadConnector<T>

java.lang.Object

nl.nn.adapterframework.stream.ThreadConnector<T>

All Implemented Interfaces:

AutoCloseable

public class ThreadConnector<T>
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
ThreadConnector(Object owner, String description, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session)
ThreadConnector(Object owner, String description, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, String correlationId)

Method Summary

Modifier and Type	Method and Description
Throwable	abortThread(Throwable t)
void	close()
<R> R	endThread(R response)
protected void	restoreThreadContext()
protected void	saveThreadContext()
<R> R	startThread(R input)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

ThreadConnector

public ThreadConnector(Object owner,
                       String description,
                       ThreadLifeCycleEventListener<T> threadLifeCycleEventListener,
                       IThreadConnectableTransactionManager txManager,
                       String correlationId)

ThreadConnector

public ThreadConnector(Object owner,
                       String description,
                       ThreadLifeCycleEventListener<T> threadLifeCycleEventListener,
                       IThreadConnectableTransactionManager txManager,
                       PipeLineSession session)

Method Detail

saveThreadContext

protected void saveThreadContext()

restoreThreadContext

protected void restoreThreadContext()

startThread

public <R> R startThread(R input)

endThread

public <R> R endThread(R response)

abortThread

public Throwable abortThread(Throwable t)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException