org.apache.oozie.service
Class JMSTopicService

java.lang.Object
  extended by 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.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.