Package org.onehippo.forge.camel.scheduling

Class DefaultCamelRepositoryJob

java.lang.Object

org.onehippo.forge.camel.scheduling.DefaultCamelRepositoryJob

All Implemented Interfaces:

org.onehippo.repository.scheduling.RepositoryJob

public class DefaultCamelRepositoryJob
extends Object
implements org.onehippo.repository.scheduling.RepositoryJob

Default RepositoryJob implementation invoking Camel endpoint.

This default RepositoryJob implementation reads attributes like the following from RepositoryJobExecutionContext:

• camel.endpoint.uri: Camel Endpoint URI to invoke. This is required.
• camel.context.id: Camel Context ID. If not provided, it retrieves the first one found.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CAMEL_CONTEXT_ID_ATTR
static final String	CAMEL_ENDPOINT_URI_ATTR

Constructor Summary

Constructors

Constructor	Description
DefaultCamelRepositoryJob()

Method Summary

Modifier and Type	Method	Description
void	execute(org.onehippo.repository.scheduling.RepositoryJobExecutionContext context)

Methods inherited from class java.lang.Object

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

Field Details

CAMEL_ENDPOINT_URI_ATTR

public static final String CAMEL_ENDPOINT_URI_ATTR

See Also:

• Constant Field Values

CAMEL_CONTEXT_ID_ATTR

public static final String CAMEL_CONTEXT_ID_ATTR

See Also:

• Constant Field Values

Constructor Details

DefaultCamelRepositoryJob

public DefaultCamelRepositoryJob()

Method Details

execute

public void execute(org.onehippo.repository.scheduling.RepositoryJobExecutionContext context)
             throws RepositoryException

Specified by:

execute in interface org.onehippo.repository.scheduling.RepositoryJob

Throws:

RepositoryException