org.apache.camel.component.jpa
Class JpaConsumer
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.impl.DefaultConsumer<E>
org.apache.camel.impl.ScheduledPollConsumer<org.apache.camel.Exchange>
org.apache.camel.component.jpa.JpaConsumer
- All Implemented Interfaces:
- Runnable, org.apache.camel.Consumer<org.apache.camel.Exchange>, org.apache.camel.Service
public class JpaConsumer
- extends org.apache.camel.impl.ScheduledPollConsumer<org.apache.camel.Exchange>
- Version:
- $Revision: 563665 $
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer |
doStart, doStop, getDelay, getInitialDelay, getTimeUnit, isUseFixedDelay, run, setDelay, setInitialDelay, setTimeUnit, setUseFixedDelay |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString |
Methods inherited from class org.apache.camel.impl.ServiceSupport |
addChildService, getThreadName, isStarted, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop |
Methods inherited from interface org.apache.camel.Service |
start, stop |
JpaConsumer
public JpaConsumer(JpaEndpoint endpoint,
org.apache.camel.Processor processor)
poll
protected void poll()
throws Exception
- Specified by:
poll
in class org.apache.camel.impl.ScheduledPollConsumer<org.apache.camel.Exchange>
- Throws:
Exception
getEndpoint
public JpaEndpoint getEndpoint()
- Overrides:
getEndpoint
in class org.apache.camel.impl.DefaultConsumer<org.apache.camel.Exchange>
getQueryFactory
public QueryFactory getQueryFactory()
setQueryFactory
public void setQueryFactory(QueryFactory queryFactory)
getDeleteHandler
public DeleteHandler getDeleteHandler()
setDeleteHandler
public void setDeleteHandler(DeleteHandler deleteHandler)
getNamedQuery
public String getNamedQuery()
setNamedQuery
public void setNamedQuery(String namedQuery)
getNativeQuery
public String getNativeQuery()
setNativeQuery
public void setNativeQuery(String nativeQuery)
getQuery
public String getQuery()
setQuery
public void setQuery(String query)
lockEntity
protected boolean lockEntity(Object entity,
javax.persistence.EntityManager entityManager)
- A strategy method to lock an object with an exclusive lock so that it can
be processed
- Parameters:
entity
- the entity to be lockedentityManager
-
- Returns:
- true if the entity was locked
createQueryFactory
protected QueryFactory createQueryFactory()
createDeleteHandler
protected DeleteHandler<Object> createDeleteHandler()
configureParameters
protected void configureParameters(javax.persistence.Query query)
createExchange
protected org.apache.camel.Exchange createExchange(Object result)
Copyright © 2007 Apache Software Foundation. All Rights Reserved.