public class ThreadConnector<T> extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
log |
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) |
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) |
public ThreadConnector(Object owner, String description, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, String correlationId)
public ThreadConnector(Object owner, String description, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session)
protected void saveThreadContext()
protected void restoreThreadContext()
public <R> R startThread(R input)
public <R> R endThread(R response)
public void close() throws IOException
close
in interface AutoCloseable
IOException
Copyright © 2023 Frank!Framework. All rights reserved.