org.hawkular.btm.server.jms

Class AbstractPublisherJMS<T>

java.lang.Object

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

All Implemented Interfaces:

Publisher<T>

Direct Known Subclasses:

BTxnCompletionInformationPublisherJMS, BTxnCompletionTimePublisherJMS, BusinessTransactionPublisherJMS, CommunicationDetailsPublisherJMS, FragmentCompletionTimePublisherJMS, NodeDetailsPublisherJMS, NotificationPublisherJMS

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 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	setInitialRetryCount(int initialRetryCount)

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()

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

close

@PreDestroy
public void close()