org.apache.oozie.service

Class JMSTopicService

java.lang.Object

org.apache.oozie.service.JMSTopicService

All Implemented Interfaces:

Service

public class JMSTopicService
extends Object
implements Service

JMS Topic service to retrieve topic names from events or job id

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JMSTopicService.JobType
static class	JMSTopicService.TopicType

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_PREFIX
static String	TOPIC_NAME
static String	TOPIC_PREFIX

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
JMSTopicService()

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroy the service.
Class<? extends Service>	getInterface() Return the public interface of the service.
String	getTopic(AppType appType, String user, String jobId, String parentJobId) Retrieve Topic
String	getTopic(String jobId) Retrieve topic from Job id
Properties	getTopicPatternProperties()
String	getTopicPrefix()
void	init(Services services) Initialize the service.

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

TOPIC_NAME

public static final String TOPIC_NAME

See Also:

Constant Field Values

TOPIC_PREFIX

public static final String TOPIC_PREFIX

See Also:

Constant Field Values

Constructor Detail

JMSTopicService

public JMSTopicService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

getTopic

public String getTopic(String jobId)
                throws JPAExecutorException

Retrieve topic from Job id

Parameters:

jobId -

Returns:

topicPrefix + topicName Retrieve topic from Job id

Throws:

JPAExecutorException

getTopic

public String getTopic(AppType appType,
                       String user,
                       String jobId,
                       String parentJobId)

Retrieve Topic

Parameters:

appType -

user -

jobId -

parentJobId -

Returns:

topicName

getTopicPatternProperties

public Properties getTopicPatternProperties()

getTopicPrefix

public String getTopicPrefix()

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.