Package org.frankframework.threading

Class ThreadConnector<T>

java.lang.Object

org.frankframework.threading.ThreadConnector<T>

Type Parameters:

T - Type of the threadInfo maintained by the ThreadLifeCycleEventListener.

All Implemented Interfaces:

AutoCloseable

public class ThreadConnector<T>
extends Object
implements AutoCloseable

Connect a parent thread and a child thread to carry over important state from the parent thread to the child thread, such as ThreadContext, thread-local hide-regexes for masking sensitive information from logs (See IbisMaskingLayout, and transaction state via a TransactionConnector.

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