public class JpaPollingChannelAdapter
extends org.springframework.integration.endpoint.AbstractMessageSource<java.lang.Object>
| Constructor and Description |
|---|
JpaPollingChannelAdapter(JpaExecutor jpaExecutor)
Constructor taking a
JpaExecutor that provide all required JPA
functionality. |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
doReceive()
Use
JpaExecutor.poll() to executes the JPA operation. |
java.lang.String |
getComponentType() |
protected void |
onInit()
Check for mandatory attributes
|
buildMessage, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServicepublic JpaPollingChannelAdapter(JpaExecutor jpaExecutor)
JpaExecutor that provide all required JPA
functionality.jpaExecutor - Must not be null.protected void onInit()
onInit in class org.springframework.integration.util.AbstractExpressionEvaluatorprotected java.lang.Object doReceive()
JpaExecutor.poll() to executes the JPA operation.
If JpaExecutor.poll() returns null, this method will return
null. Otherwise, a new Message is constructed and returned.doReceive in class org.springframework.integration.endpoint.AbstractMessageSource<java.lang.Object>public java.lang.String getComponentType()