org.apache.camel.component.jcr

Class JcrEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.component.jcr.JcrEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@UriEndpoint(scheme="jcr",
             consumerClass=JcrConsumer.class)
public class JcrEndpoint
extends org.apache.camel.impl.DefaultEndpoint

A JCR endpoint

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JcrEndpoint(String endpointUri, JcrComponent component)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected String	getBase() Get the base node when accessing the reposititory
protected javax.jcr.Credentials	getCredentials() Get the Credentials for establishing the JCR repository connection
String	getEndpointConfiguredDestinationName() Gets the destination name which was configured from the endpoint uri.
int	getEventTypes() eventTypes (a combination of one or more event types encoded as a bit mask value such as javax.jcr.observation.Event.NODE_ADDED, javax.jcr.observation.Event.NODE_REMOVED, etc.).
String	getNodeTypeNames() When a comma separated nodeTypeName list string is set, only events whose associated parent node has one of the node types (or a subtype of one of the node types) in this list will be received.
protected javax.jcr.Repository	getRepository() Get the Repository
long	getSessionLiveCheckInterval() Interval in milliseconds to wait before each session live checking The default value is 60000 ms.
long	getSessionLiveCheckIntervalOnStart() Interval in milliseconds to wait before the first session live checking.
String	getUuids() When a comma separated uuid list string is set, only events whose associated parent node has one of the identifiers in the comma separated uuid list will be received.
boolean	isDeep() When isDeep is true, events whose associated parent node is at absPath or within its subgraph are received.
boolean	isNoLocal() If noLocal is true, then events generated by the session through which the listener was registered are ignored.
boolean	isSingleton()
void	setDeep(boolean deep)
void	setEventTypes(int eventTypes)
void	setNodeTypeNames(String nodeTypeNames)
void	setNoLocal(boolean noLocal)
void	setSessionLiveCheckInterval(long sessionLiveCheckInterval)
void	setSessionLiveCheckIntervalOnStart(long sessionLiveCheckIntervalOnStart)
void	setUuids(String uuids)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

JcrEndpoint

protected JcrEndpoint(String endpointUri,
           JcrComponent component)

Method Detail

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

getRepository

protected javax.jcr.Repository getRepository()

Get the Repository

Returns:

the repository

getCredentials

protected javax.jcr.Credentials getCredentials()

Get the Credentials for establishing the JCR repository connection

Returns:

the credentials

getBase

protected String getBase()

Get the base node when accessing the reposititory

Returns:

the base node

getEventTypes

public int getEventTypes()

eventTypes (a combination of one or more event types encoded as a bit mask value such as javax.jcr.observation.Event.NODE_ADDED, javax.jcr.observation.Event.NODE_REMOVED, etc.).

Returns:

eventTypes

See Also:

javax.jcr.observation.Event}, javax.jcr.observation.ObservationManager#addEventListener(javax.jcr.observation.EventListener, int, String, boolean, String[], String[], boolean)}

setEventTypes

public void setEventTypes(int eventTypes)

isDeep

public boolean isDeep()

When isDeep is true, events whose associated parent node is at absPath or within its subgraph are received.

Returns:

deep

setDeep

public void setDeep(boolean deep)

getUuids

public String getUuids()

When a comma separated uuid list string is set, only events whose associated parent node has one of the identifiers in the comma separated uuid list will be received.

Returns:

comma separated uuid list string

setUuids

public void setUuids(String uuids)

getNodeTypeNames

public String getNodeTypeNames()

When a comma separated nodeTypeName list string is set, only events whose associated parent node has one of the node types (or a subtype of one of the node types) in this list will be received.

Returns:

setNodeTypeNames

public void setNodeTypeNames(String nodeTypeNames)

isNoLocal

public boolean isNoLocal()

If noLocal is true, then events generated by the session through which the listener was registered are ignored. Otherwise, they are not ignored.

Returns:

noLocal

setNoLocal

public void setNoLocal(boolean noLocal)

getSessionLiveCheckIntervalOnStart

public long getSessionLiveCheckIntervalOnStart()

Interval in milliseconds to wait before the first session live checking. The default value is 3000 ms.

Returns:

sessionLiveCheckIntervalOnStart

setSessionLiveCheckIntervalOnStart

public void setSessionLiveCheckIntervalOnStart(long sessionLiveCheckIntervalOnStart)

getSessionLiveCheckInterval

public long getSessionLiveCheckInterval()

Interval in milliseconds to wait before each session live checking The default value is 60000 ms.

Returns:

setSessionLiveCheckInterval

public void setSessionLiveCheckInterval(long sessionLiveCheckInterval)

getEndpointConfiguredDestinationName

public String getEndpointConfiguredDestinationName()

Gets the destination name which was configured from the endpoint uri.

Returns:

the destination name resolved from the endpoint uri