org.gytheio.content

Class AbstractAsyncComponent<W extends org.gytheio.content.ContentWorker,RQ extends Request<RP>,RP extends Reply>

java.lang.Object

org.gytheio.content.AbstractComponent<W>

org.gytheio.content.AbstractAsyncComponent<W,RQ,RP>

Type Parameters:

W -

RQ -

RP -

All Implemented Interfaces:

Component, MessageConsumer

public abstract class AbstractAsyncComponent<W extends org.gytheio.content.ContentWorker,RQ extends Request<RP>,RP extends Reply>
extends AbstractComponent<W>

Base component which pulls a message off the queue before performing the work, useful when progress reporting is needed as some messaging endpoints will lock the session until the message consumption is complete and progress replies can not be sent.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractAsyncComponent.LocalQueueProcessor Takes from the local concurrent queue and hands them off to be processed

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executorService

Fields inherited from class org.gytheio.content.AbstractComponent

messageProducer, name, worker

Constructor Summary

Constructors

Constructor and Description
AbstractAsyncComponent()

Method Summary

Methods

Modifier and Type	Method and Description
void	init()
protected void	onReceiveImpl(Object message)
protected abstract void	processRequest(RQ request) Performs the actual work for the request.
void	setExecutorService(ExecutorService executorService) Sets the executor service components may optionally need for running separate threads.

Methods inherited from class org.gytheio.content.AbstractComponent

getName, getWorkerVersionDetailsString, getWorkerVersionString, isWorkerAvailable, onReceive, setMessageProducer, setName, setWorker, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gytheio.messaging.MessageConsumer

getConsumingMessageBodyClass

Field Detail

executorService

protected ExecutorService executorService

Constructor Detail

AbstractAsyncComponent

public AbstractAsyncComponent()

Method Detail

setExecutorService

public void setExecutorService(ExecutorService executorService)

Sets the executor service components may optionally need for running separate threads.

Parameters:

executorService -

onReceiveImpl

protected void onReceiveImpl(Object message)

Specified by:

onReceiveImpl in class AbstractComponent<W extends org.gytheio.content.ContentWorker>

processRequest

protected abstract void processRequest(RQ request)

Performs the actual work for the request.

Parameters:

request -

init

public void init()

Overrides:

init in class AbstractComponent<W extends org.gytheio.content.ContentWorker>