@UriEndpoint(scheme="jcr", title="JCR", syntax="jcr:host/base", alternativeSyntax="jcr:username:password@host/base", consumerClass=JcrConsumer.class, label="cms,database") public class JcrEndpoint extends DefaultEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Modifier | Constructor and Description |
---|---|
protected |
JcrEndpoint(String endpointUri,
JcrComponent component) |
Modifier and Type | Method and Description |
---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected String |
getBase()
Get the base node when accessing the repository
|
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 |
getHost() |
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. |
String |
getPassword() |
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 |
getUsername() |
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.
|
String |
getWorkspaceName()
The workspace to access.
|
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()
Whether this class supports being singleton or not.
|
void |
setBase(String base) |
void |
setDeep(boolean deep) |
void |
setEventTypes(int eventTypes) |
void |
setHost(String host)
Name of the
Repository to lookup from the Camel registry to be used. |
void |
setNodeTypeNames(String nodeTypeNames) |
void |
setNoLocal(boolean noLocal) |
void |
setPassword(String password)
Password for login
|
void |
setSessionLiveCheckInterval(long sessionLiveCheckInterval) |
void |
setSessionLiveCheckIntervalOnStart(long sessionLiveCheckIntervalOnStart) |
void |
setUsername(String username)
Username for login
|
void |
setUuids(String uuids) |
void |
setWorkspaceName(String workspaceName) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected JcrEndpoint(String endpointUri, JcrComponent component)
public Consumer createConsumer(Processor processor) throws Exception
Endpoint
processor
- the given processorException
- can be thrownpublic Producer createProducer() throws Exception
Endpoint
Exception
- can be thrownpublic boolean isSingleton()
IsSingleton
protected void doStart() throws Exception
ServiceSupport
ServiceSupport.doStop()
for more details.doStart
in class DefaultEndpoint
Exception
ServiceSupport.doStop()
public String getHost()
public void setHost(String host)
Repository
to lookup from the Camel registry to be used.protected javax.jcr.Repository getRepository()
Repository
protected javax.jcr.Credentials getCredentials()
Credentials
for establishing the JCR repository connectionprotected String getBase()
public void setBase(String base)
public String getUsername()
public void setUsername(String username)
public String getPassword()
public void setPassword(String password)
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.).javax.jcr.observation.Event}
,
javax.jcr.observation.ObservationManager#addEventListener(javax.jcr.observation.EventListener, int, String, boolean, String[], String[], boolean)}
public void setEventTypes(int eventTypes)
public boolean isDeep()
isDeep
is true, events whose associated parent node is at
absPath
or within its subgraph are received.public void setDeep(boolean deep)
public String getUuids()
public void setUuids(String uuids)
public String getNodeTypeNames()
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.public void setNodeTypeNames(String nodeTypeNames)
public boolean isNoLocal()
noLocal
is true
, then events
generated by the session through which the listener was registered are
ignored. Otherwise, they are not ignored.public void setNoLocal(boolean noLocal)
public long getSessionLiveCheckIntervalOnStart()
public void setSessionLiveCheckIntervalOnStart(long sessionLiveCheckIntervalOnStart)
public long getSessionLiveCheckInterval()
public void setSessionLiveCheckInterval(long sessionLiveCheckInterval)
public String getWorkspaceName()
public void setWorkspaceName(String workspaceName)
public String getEndpointConfiguredDestinationName()
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.