org.gytheio.content.transform

Class BaseContentTransformerComponent

java.lang.Object

org.gytheio.content.AbstractComponent<W>

org.gytheio.content.AbstractAsyncComponent<org.gytheio.content.transform.ContentTransformerWorker,org.gytheio.content.transform.TransformationRequest,org.gytheio.content.transform.TransformationReply>

org.gytheio.content.transform.BaseContentTransformerComponent

All Implemented Interfaces:

org.gytheio.content.Component, org.gytheio.messaging.MessageConsumer

public class BaseContentTransformerComponent
extends org.gytheio.content.AbstractAsyncComponent<org.gytheio.content.transform.ContentTransformerWorker,org.gytheio.content.transform.TransformationRequest,org.gytheio.content.transform.TransformationReply>

A base implementation of a transform node which receives messages, uses a ContentTransformerWorker to perform the transformation, then uses a MessageProducer to send the reply.

Author:

Ray Gauss II

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BaseContentTransformerComponent.ContentTransformerWorkerProgressReporterImpl Implementation of the progress reporter which sends reply messages with progress on the transformation.

Nested classes/interfaces inherited from class org.gytheio.content.AbstractAsyncComponent

org.gytheio.content.AbstractAsyncComponent.LocalQueueProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected org.gytheio.content.transform.TransformationRequest	lastRequest

Fields inherited from class org.gytheio.content.AbstractComponent

executorService, messageProducer, worker

Constructor Summary

Constructors

Constructor and Description
BaseContentTransformerComponent()

Method Summary

Methods

Modifier and Type	Method and Description
Class<?>	getConsumingMessageBodyClass()
org.gytheio.content.transform.TransformationRequest	getLastRequest() Gets the last transformation request received.
protected void	processRequest(org.gytheio.content.transform.TransformationRequest request)

Methods inherited from class org.gytheio.content.AbstractAsyncComponent

init, onReceiveImpl

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

Field Detail

lastRequest

protected org.gytheio.content.transform.TransformationRequest lastRequest

Constructor Detail

BaseContentTransformerComponent

public BaseContentTransformerComponent()

Method Detail

getLastRequest

public org.gytheio.content.transform.TransformationRequest getLastRequest()

Gets the last transformation request received.

This is simply the last request, stored in-memory, with no indication as to it's status, it may have been completed days ago.

Returns:

the last request received

processRequest

protected void processRequest(org.gytheio.content.transform.TransformationRequest request)

Specified by:

processRequest in class org.gytheio.content.AbstractAsyncComponent<org.gytheio.content.transform.ContentTransformerWorker,org.gytheio.content.transform.TransformationRequest,org.gytheio.content.transform.TransformationReply>

getConsumingMessageBodyClass

public Class<?> getConsumingMessageBodyClass()