org.hawkular.apm.server.jms

Class RetryCapableMDB<S,T>

java.lang.Object

org.hawkular.apm.server.jms.RetryCapableMDB<S,T>

Type Parameters:

S - Source event type

T - Target event type

All Implemented Interfaces:

javax.jms.MessageListener

Direct Known Subclasses:

CommunicationDetailsCacheMDB, CommunicationDetailsDeriverMDB, CommunicationDetailsStoreMDB, FragmentCompletionTimeDeriverMDB, FragmentCompletionTimeStoreMDB, NodeDetailsDeriverMDB, NodeDetailsStoreMDB, NotificationDeriverMDB, TraceCompletionInformationInitiatorMDB, TraceCompletionInformationProcessorMDB, TraceCompletionTimeDeriverMDB, TraceCompletionTimeStoreMDB, TraceStoreMDB

public abstract class RetryCapableMDB<S,T>
extends Object
implements javax.jms.MessageListener

This class represents a MDB based class to handle processing of events, publication of results, and resubmission of failed events using a retry mechanism.

Author:

gbrown

Constructor Summary

Constructors

Constructor and Description
RetryCapableMDB(String subscriberName) This constructor initialises the retry capable MDB with the subscriber name.

Method Summary

Modifier and Type	Method and Description
Processor<S,T>	getProcessor()
Publisher<T>	getPublisher()
AbstractPublisherJMS<S>	getRetryPublisher()
com.fasterxml.jackson.core.type.TypeReference<List<S>>	getTypeReference()
void	onMessage(javax.jms.Message message)
protected void	process(String tenantId, List<S> items, int retryCount) This method processes the received list of items.
void	setProcessor(Processor<S,T> processor)
void	setPublisher(Publisher<T> publisher)
void	setRetryPublisher(AbstractPublisherJMS<S> retryPublisher)
void	setTypeReference(com.fasterxml.jackson.core.type.TypeReference<List<S>> typeReference)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryCapableMDB

public RetryCapableMDB(String subscriberName)

This constructor initialises the retry capable MDB with the subscriber name.

Parameters:

subscriberName - The subscriber name

Method Detail

getProcessor

public Processor<S,T> getProcessor()

Returns:

the processor

setProcessor

public void setProcessor(Processor<S,T> processor)

Parameters:

processor - the processor to set

getPublisher

public Publisher<T> getPublisher()

Returns:

the publisher

setPublisher

public void setPublisher(Publisher<T> publisher)

Parameters:

publisher - the publisher to set

getRetryPublisher

public AbstractPublisherJMS<S> getRetryPublisher()

Returns:

the retryPublisher

setRetryPublisher

public void setRetryPublisher(AbstractPublisherJMS<S> retryPublisher)

Parameters:

retryPublisher - the retryPublisher to set

getTypeReference

public com.fasterxml.jackson.core.type.TypeReference<List<S>> getTypeReference()

Returns:

the typeReference

setTypeReference

public void setTypeReference(com.fasterxml.jackson.core.type.TypeReference<List<S>> typeReference)

Parameters:

typeReference - the typeReference to set

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

process

protected void process(String tenantId,
                       List<S> items,
                       int retryCount)
                throws Exception

This method processes the received list of items.

Parameters:

tenantId - The optional tenant id

items - The items

retryCount - The remaining retry count

Throws:

Failed - to process items

Exception