io.micronaut.jms.listener

Class ConcurrentMessageHandler<T>

java.lang.Object

io.micronaut.jms.listener.ConcurrentMessageHandler<T>

Type Parameters:

T - the type of the object that the handler is expecting.

All Implemented Interfaces:

MessageHandler<T>

public class ConcurrentMessageHandler<T>
extends java.lang.Object
implements MessageHandler<T>

A MessageHandler decorator that wraps a delegate implementation in an ExecutorService to handle many incoming messages concurrently on different threads. A default single-threaded executor is provided if no ExecutorService is provided.

Since:

1.0.0

Author:

Elliott Pope

Constructor Summary

Constructors

Constructor and Description
ConcurrentMessageHandler(MessageHandler<T> delegate) Submits incoming handling requests on a single threaded executor to avoid blocking the main thread.
ConcurrentMessageHandler(MessageHandler<T> delegate, java.util.concurrent.ExecutorService executorService) Allows for concurrent handling of messages by handing of the logic to a delegate MessageHandler but wrapping those calls within an Executor.execute(Runnable).

Method Summary

Modifier and Type	Method and Description
void	handle(T message) Perform some action when receiving a message.
boolean	shutdown() Closes the MessageHandler and terminates the executorService.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentMessageHandler

public ConcurrentMessageHandler(MessageHandler<T> delegate,
                                java.util.concurrent.ExecutorService executorService)

Allows for concurrent handling of messages by handing of the logic to a delegate MessageHandler but wrapping those calls within an Executor.execute(Runnable).

Parameters:

delegate - the MessageHandler to actually handle the incoming messages

executorService - the ExecutorService to submit handling requests to.

ConcurrentMessageHandler

public ConcurrentMessageHandler(MessageHandler<T> delegate)

Submits incoming handling requests on a single threaded executor to avoid blocking the main thread.

Parameters:

delegate - the MessageHandler to actually handle the incoming messages/

Method Detail

handle

public void handle(T message)

Description copied from interface: MessageHandler

Perform some action when receiving a message.

Specified by:

handle in interface MessageHandler<T>

Parameters:

message - the message

shutdown

public boolean shutdown()
                 throws java.lang.InterruptedException

Closes the MessageHandler and terminates the executorService.

Returns:

true if the executorService is successfully shut down.

Throws:

java.lang.InterruptedException - if there is a timeout waiting for the executor service to shut down