org.apache.oozie.service

Class CallbackService

java.lang.Object

org.apache.oozie.service.CallbackService

All Implemented Interfaces:

Service

public class CallbackService
extends java.lang.Object
implements Service

Service that generates and parses callback URLs.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_BASE_URL
static java.lang.String	CONF_EARLY_REQUEUE_MAX_RETRIES
static java.lang.String	CONF_PREFIX

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
CallbackService()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	createCallBackUrl(java.lang.String actionId, java.lang.String externalStatusVar) Create a callback URL.
void	destroy() Destroy the service.
java.lang.String	getActionId(java.lang.String callback) Return the action ID from a callback URL.
int	getEarlyRequeueMaxRetries()
java.lang.String	getExternalStatus(java.lang.String callback) Return the action external status from a callback URL.
java.lang.Class<? extends Service>	getInterface() Return the public interface of the Dag engine service.
void	init(Services services) Initialize the service.
boolean	isValid(java.lang.String callback) Return if a callback URL is valid or not.

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 java.lang.String CONF_PREFIX

See Also:

Constant Field Values

CONF_BASE_URL

public static final java.lang.String CONF_BASE_URL

See Also:

Constant Field Values

CONF_EARLY_REQUEUE_MAX_RETRIES

public static final java.lang.String CONF_EARLY_REQUEUE_MAX_RETRIES

See Also:

Constant Field Values

Constructor Detail

CallbackService

public CallbackService()

Method Detail

init

public void init(Services services)

Initialize the service.

Specified by:

init in interface Service

Parameters:

services - services instance.

destroy

public void destroy()

Destroy the service.

Specified by:

destroy in interface Service

getInterface

public java.lang.Class<? extends Service> getInterface()

Return the public interface of the Dag engine service.

Specified by:

getInterface in interface Service

Returns:

CallbackService.

createCallBackUrl

public java.lang.String createCallBackUrl(java.lang.String actionId,
                                 java.lang.String externalStatusVar)

Create a callback URL.

Parameters:

actionId - action ID for the callback URL.

externalStatusVar - variable for the caller to inject the external status.

Returns:

the callback URL.

isValid

public boolean isValid(java.lang.String callback)

Return if a callback URL is valid or not.

Parameters:

callback - callback URL (it can be just the callback portion of it).

Returns:

true if the callback URL is valid, false if it is not.

getActionId

public java.lang.String getActionId(java.lang.String callback)

Return the action ID from a callback URL.

Parameters:

callback - callback URL (it can be just the callback portion of it).

Returns:

the action ID from a callback URL.

getExternalStatus

public java.lang.String getExternalStatus(java.lang.String callback)

Return the action external status from a callback URL.

Parameters:

callback - callback URL (it can be just the callback portion of it).

Returns:

the action external status from a callback URL.

getEarlyRequeueMaxRetries

public int getEarlyRequeueMaxRetries()