org.hawkular.apm.server.jms

Class AbstractPublisherJMS<T>

java.lang.Object

org.hawkular.apm.server.jms.AbstractPublisherJMS<T>

All Implemented Interfaces:

Publisher<T>

Direct Known Subclasses:

CommunicationDetailsPublisherJMS, FragmentCompletionTimePublisherJMS, NodeDetailsPublisherJMS, NotificationPublisherJMS, TraceCompletionInformationPublisherJMS, TraceCompletionTimePublisherJMS, TracePublisherJMS

public abstract class AbstractPublisherJMS<T>
extends Object
implements Publisher<T>

This abstract class represents a JMS publisher.

Author:

gbrown

Constructor Summary

Constructors

Constructor and Description
AbstractPublisherJMS()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	doPublish(String tenantId, List<T> items, String subscriber, int retryCount, long delay) This method publishes the supplied items.
protected abstract String	getDestinationURI() This method returns the destination associated with the publisher.
int	getInitialRetryCount()
void	init()
void	publish(String tenantId, List<T> items)
void	publish(String tenantId, List<T> items, int retryCount, long delay)
void	retry(String tenantId, List<T> items, String subscriber, int retryCount, long delay)
void	setInitialRetryCount(int initialRetryCount)
void	setMetricHandler(PublisherMetricHandler<T> handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPublisherJMS

public AbstractPublisherJMS()

Method Detail

getDestinationURI

protected abstract String getDestinationURI()

This method returns the destination associated with the publisher.

Returns:

The destination

getInitialRetryCount

public int getInitialRetryCount()

Specified by:

getInitialRetryCount in interface Publisher<T>

Returns:

the initialRetryCount

setInitialRetryCount

public void setInitialRetryCount(int initialRetryCount)

Parameters:

initialRetryCount - the initialRetryCount to set

init

@PostConstruct
public void init()

doPublish

protected void doPublish(String tenantId,
                         List<T> items,
                         String subscriber,
                         int retryCount,
                         long delay)
                  throws Exception

This method publishes the supplied items.

Parameters:

tenantId - The tenant id

items - The items

subscriber - The optional subscriber name

retryCount - The retry count

delay - The delay

Throws:

Exception - Failed to publish

publish

public void publish(String tenantId,
                    List<T> items,
                    int retryCount,
                    long delay)
             throws Exception

Specified by:

publish in interface Publisher<T>

Throws:

Exception

publish

public void publish(String tenantId,
                    List<T> items)
             throws Exception

Specified by:

publish in interface Publisher<T>

Throws:

Exception

retry

public void retry(String tenantId,
                  List<T> items,
                  String subscriber,
                  int retryCount,
                  long delay)
           throws Exception

Specified by:

retry in interface Publisher<T>

Throws:

Exception

close

@PreDestroy
public void close()

setMetricHandler

public void setMetricHandler(PublisherMetricHandler<T> handler)

Specified by:

setMetricHandler in interface Publisher<T>