Package io.awspring.cloud.sqs

Class MessageExecutionThreadFactory

java.lang.Object

org.springframework.util.CustomizableThreadCreator

org.springframework.scheduling.concurrent.CustomizableThreadFactory

io.awspring.cloud.sqs.MessageExecutionThreadFactory

All Implemented Interfaces:

Serializable, ThreadFactory

public class MessageExecutionThreadFactory
extends CustomizableThreadFactory

CustomizableThreadFactory implementation for creating MessageExecutionThread instances. This should be set to TaskExecutor instances provided by ContainerOptions.getComponentsTaskExecutor() to avoid excessive thread hopping for blocking components.

Since:

3.0

Author:

Tomaz Fernandes

See Also:

• MessageExecutionThread
• AsyncComponentAdapters
• Serialized Form

Constructor Summary

Constructors

Constructor	Description
MessageExecutionThreadFactory()	Create a new MessageExecutionThreadFactory with default thread name prefix.
MessageExecutionThreadFactory(String threadNamePrefix)	Create a new MessageExecutionThreadFactory with the given thread name prefix.

Method Summary

Modifier and Type	Method	Description
Thread	createThread(Runnable runnable)

Methods inherited from class org.springframework.scheduling.concurrent.CustomizableThreadFactory

newThread

Methods inherited from class org.springframework.util.CustomizableThreadCreator

getDefaultThreadNamePrefix, getThreadGroup, getThreadNamePrefix, getThreadPriority, isDaemon, nextThreadName, setDaemon, setThreadGroup, setThreadGroupName, setThreadNamePrefix, setThreadPriority

Methods inherited from class java.lang.Object

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

Constructor Details

MessageExecutionThreadFactory

public MessageExecutionThreadFactory()

Create a new MessageExecutionThreadFactory with default thread name prefix.

MessageExecutionThreadFactory

public MessageExecutionThreadFactory(String threadNamePrefix)

Create a new MessageExecutionThreadFactory with the given thread name prefix.

Parameters:

threadNamePrefix - the prefix to use for the names of newly created threads

Method Details

createThread

public Thread createThread(Runnable runnable)

Overrides:

createThread in class CustomizableThreadCreator