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 inherited from class org.gytheio.content.AbstractComponent

executorService, messageProducer, 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.

Methods inherited from class org.gytheio.content.AbstractComponent

onReceive, setExecutorService, setMessageProducer, 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

Constructor Detail

AbstractAsyncComponent

public AbstractAsyncComponent()

Method Detail

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>