Package org.frankframework.stream

Class ThreadConnector<T>

java.lang.Object

org.frankframework.stream.ThreadConnector<T>

All Implemented Interfaces:

AutoCloseable

public class ThreadConnector<T>
extends Object
implements AutoCloseable

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

log

protected org.apache.logging.log4j.Logger log

Constructor Details

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 Details

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()

Specified by:

close in interface AutoCloseable