Package com.adaptris.core

Class AdaptrisMessageWorkerImp

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

Direct Known Subclasses:

AdaptrisMessageConsumerImp, AdaptrisMessageProducerImp

public abstract class AdaptrisMessageWorkerImp
extends Object
implements AdaptrisMessageWorker

Implementation of behaviour common to AdaptrisMessageConsumer and AdaptrisMessageProducer.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
AdaptrisMessageWorkerImp()

Method Summary

Modifier and Type	Method	Description
String	createName()	Create a name for any MleMarker that is generated.
String	createQualifier()	Create a qualifier for any MleMarker that is generated.
AdaptrisMessage	decode(byte[] bytes)	Decodes the passed byte[] using the configured AdaptrisMessageEncoder.
byte[]	encode(AdaptrisMessage msg)	Encode the passed message using the configured AdaptrisMessageEncoder.
AdaptrisMessageEncoder	getEncoder()	Returns the AdaptrisMessageEncoder to use.
Boolean	getIsTrackingEndpoint()
AdaptrisMessageFactory	getMessageFactory()
String	getUniqueId()	Get the unique-id that is associated with this component.
void	handleConnectionException()	Called if a connection exception is encountered.
boolean	isTrackingEndpoint()	Returns true if this should be considered an 'end-point' for tracking purposes, otherwise false.
void	registerConnection(AdaptrisConnection conn)	Sets the AdaptrisConnection this component will use.
protected void	registerEncoderMessageFactory()
<T> T	retrieveConnection(Class<T> type)	Return this components underlying connection.
void	setEncoder(AdaptrisMessageEncoder enc)	Sets the AdaptrisMessageEncoder to use.
void	setIsTrackingEndpoint(Boolean b)
void	setMessageFactory(AdaptrisMessageFactory f)	Set the message factory used when creating AdaptrisMessage instances.
void	setUniqueId(String s)
<T extends AdaptrisMessageWorkerImp> T	withMessageFactory(AdaptrisMessageFactory f)
<T extends AdaptrisMessageWorkerImp> T	withUniqueID(String uid)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Methods inherited from interface com.adaptris.core.ComponentLifecycleExtension

prepare

Field Details

log

protected transient org.slf4j.Logger log

Constructor Details

AdaptrisMessageWorkerImp

public AdaptrisMessageWorkerImp()

Method Details

handleConnectionException

public void handleConnectionException()
                               throws CoreException

Description copied from interface: AdaptrisMessageWorker

Called if a connection exception is encountered. Generally this will be when a polling consumer fails to obtain input, when a producer fails to produce or when some third party thread such as JMS exception listener is invoked.

Specified by:

handleConnectionException in interface AdaptrisMessageWorker

Throws:

CoreException - wrapping underlying Exceptions

See Also:

• #handleConnectionException()

createName

public String createName()

Description copied from interface: MessageEventGenerator

Create a name for any MleMarker that is generated.

The default implementation is to return the classname of the component in question.

* @return the name for any MleMarker that is generated.

Specified by:

createName in interface MessageEventGenerator

createQualifier

public String createQualifier()

Description copied from interface: MessageEventGenerator

Create a qualifier for any MleMarker that is generated.

The default implementation is to return the unique-id of the component in question, or the empty string if not configured

Specified by:

createQualifier in interface MessageEventGenerator

Returns:

the qualifier for any MleMarker that is generated.

encode

public byte[] encode(AdaptrisMessage msg)
              throws CoreException

Description copied from interface: AdaptrisMessageWorker

Encode the passed message using the configured AdaptrisMessageEncoder. If no AME is configured implementations should return msg.getBytes().

Specified by:

encode in interface AdaptrisMessageWorker

Parameters:

msg - the AdaptrisMessage to encode

Returns:

the AdaptrisMessage encoded as a byte[]

Throws:

CoreException - wrapping any that occur

decode

public AdaptrisMessage decode(byte[] bytes)
                       throws CoreException

Description copied from interface: AdaptrisMessageWorker

Decodes the passed byte[] using the configured AdaptrisMessageEncoder. If no AME is configured, implementations should just set the byte[] as the payload of a new message.

Specified by:

decode in interface AdaptrisMessageWorker

Parameters:

bytes - the byte[] to decode

Returns:

an AdaptrisMessage

Throws:

CoreException - wrapping any that occur

getEncoder

public AdaptrisMessageEncoder getEncoder()

Description copied from interface: AdaptrisMessageWorker

Returns the AdaptrisMessageEncoder to use.

Specified by:

getEncoder in interface AdaptrisMessageWorker

Returns:

the AdaptrisMessageEncoder to use

setEncoder

public void setEncoder(AdaptrisMessageEncoder enc)

Description copied from interface: AdaptrisMessageWorker

Sets the AdaptrisMessageEncoder to use.

Specified by:

setEncoder in interface AdaptrisMessageWorker

Parameters:

enc - the AdaptrisMessageEncoder to use

retrieveConnection

public <T> T retrieveConnection(Class<T> type)

Description copied from interface: AdaptrisMessageWorker

Return this components underlying connection.

Specified by:

retrieveConnection in interface AdaptrisMessageWorker

Parameters:

type - the type of connection to cast to.

Returns:

the connection

registerConnection

public void registerConnection(AdaptrisConnection conn)

Description copied from interface: AdaptrisMessageWorker

Sets the AdaptrisConnection this component will use.

Specified by:

registerConnection in interface AdaptrisMessageWorker

Parameters:

conn - the AdaptrisConnection to use

getUniqueId

public String getUniqueId()

Description copied from interface: AdaptrisComponent

Get the unique-id that is associated with this component.

Specified by:

getUniqueId in interface AdaptrisComponent

Returns:

the unique-id

setUniqueId

public void setUniqueId(String s)

getIsTrackingEndpoint

public Boolean getIsTrackingEndpoint()

isTrackingEndpoint

public boolean isTrackingEndpoint()

Description copied from interface: MessageEventGenerator

Returns true if this should be considered an 'end-point' for tracking purposes, otherwise false.

Specified by:

isTrackingEndpoint in interface MessageEventGenerator

Returns:

true if this should be considered an 'end-point' for tracking purposes, otherwise false

setIsTrackingEndpoint

public void setIsTrackingEndpoint(Boolean b)

getMessageFactory

public AdaptrisMessageFactory getMessageFactory()

Specified by:

getMessageFactory in interface AdaptrisMessageWorker

Returns:

the messageFactory

setMessageFactory

public void setMessageFactory(AdaptrisMessageFactory f)

Description copied from interface: AdaptrisMessageWorker

Set the message factory used when creating AdaptrisMessage instances.

Specified by:

setMessageFactory in interface AdaptrisMessageWorker

Parameters:

f - the messageFactory to set

withMessageFactory

public <T extends AdaptrisMessageWorkerImp> T withMessageFactory(AdaptrisMessageFactory f)

withUniqueID

public <T extends AdaptrisMessageWorkerImp> T withUniqueID(String uid)

registerEncoderMessageFactory

protected void registerEncoderMessageFactory()