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
DefaultRepositoryJob
implementation invoking Camel endpoint.This default
RepositoryJob
implementation reads attributes like the following fromRepositoryJobExecutionContext
: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 String
CAMEL_CONTEXT_ID_ATTR
static String
CAMEL_ENDPOINT_URI_ATTR
-
Constructor Summary
Constructors Constructor Description DefaultCamelRepositoryJob()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
execute(org.onehippo.repository.scheduling.RepositoryJobExecutionContext context)
-
-
-
Field Detail
-
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
-
-
Method Detail
-
execute
public void execute(org.onehippo.repository.scheduling.RepositoryJobExecutionContext context) throws RepositoryException
- Specified by:
execute
in interfaceorg.onehippo.repository.scheduling.RepositoryJob
- Throws:
RepositoryException
-
-