org.hawaiiframework.async

Class AbortableTaskDecorator

java.lang.Object

org.hawaiiframework.async.AbortableTaskDecorator

All Implemented Interfaces:

org.springframework.core.task.TaskDecorator

public class AbortableTaskDecorator
extends java.lang.Object
implements org.springframework.core.task.TaskDecorator

Task decorator to copy the MDC from the calling thread to the executing thread..

Since:

2.0.0

Author:

Rutger Lubbers, Paul Klos

Constructor Summary

Constructors

Constructor and Description
AbortableTaskDecorator(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor, java.util.concurrent.ScheduledThreadPoolExecutor timeoutExecutor) Construct an instance.

Method Summary

Modifier and Type	Method and Description
java.lang.Runnable	decorate(java.lang.Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbortableTaskDecorator

public AbortableTaskDecorator(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor,
                              java.util.concurrent.ScheduledThreadPoolExecutor timeoutExecutor)

Construct an instance.

Method Detail

decorate

public java.lang.Runnable decorate(java.lang.Runnable runnable)

We create a new AbortableTaskRunnable that holds the current thread's MDC. This is for logging purposes, so that logging within the runnable is done with the correct logging context. For instance, the transaction id is logged and the current user etc.

Next to this, we create an schedule a TimeoutGuardTask. This task will stop the runnable we're decorating if the configured timeout has lapsed.

The AbortableTaskRunnable will stop the execution of the TimeoutGuardTask after it completes.

Specified by:

decorate in interface org.springframework.core.task.TaskDecorator