This project has retired. For details please refer to its Attic page.

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

static class	JMSTopicService.JobType
static class	JMSTopicService.TopicType

Field Summary

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, USE_XCOMMAND

Constructor Summary

JMSTopicService()

Method Summary

void	destroy() Destroy the service.
Class<? extends Service>	getInterface() Return the public interface of the service.
String	getTopic(org.apache.oozie.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:

Throws:

JPAExecutorException

getTopic

public String getTopic(org.apache.oozie.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.