org.gytheio.content

Class AbstractComponent<W extends org.gytheio.content.ContentWorker>

java.lang.Object

org.gytheio.content.AbstractComponent<W>

Type Parameters:

W -

All Implemented Interfaces:

Component, MessageConsumer

Direct Known Subclasses:

AbstractAsyncComponent

public abstract class AbstractComponent<W extends org.gytheio.content.ContentWorker>
extends Object
implements Component

Base implementation of a component with content worker and messageProducer fields.

Author:

Ray Gauss II

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executorService
protected MessageProducer	messageProducer
protected W	worker

Constructor Summary

Constructors

Constructor and Description
AbstractComponent()

Method Summary

Methods

Modifier and Type	Method and Description
void	init()
void	onReceive(Object message) Performs any processing required upon receiving the given POJO message
protected abstract void	onReceiveImpl(Object message)
void	setExecutorService(ExecutorService executorService) Sets the executor service components may optionally need for running separate threads.
void	setMessageProducer(MessageProducer messageProducer) Sets the message producer used to send replies
void	setWorker(W worker) Sets the transformer worker which does the actual work of the transformation
String	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

worker

protected W extends org.gytheio.content.ContentWorker worker

messageProducer

protected MessageProducer messageProducer

executorService

protected ExecutorService executorService

Constructor Detail

AbstractComponent

public AbstractComponent()

Method Detail

setWorker

public void setWorker(W worker)

Sets the transformer worker which does the actual work of the transformation

Parameters:

transformerWorker -

setMessageProducer

public void setMessageProducer(MessageProducer messageProducer)

Sets the message producer used to send replies

Parameters:

messageProducer -

setExecutorService

public void setExecutorService(ExecutorService executorService)

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

Parameters:

executorService -

init

public void init()

onReceive

public void onReceive(Object message)

Description copied from interface: MessageConsumer

Performs any processing required upon receiving the given POJO message

Specified by:

onReceive in interface MessageConsumer

onReceiveImpl

protected abstract void onReceiveImpl(Object message)

toString

public String toString()

Overrides:

toString in class Object