Package 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 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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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)
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
-
-