public class JpaPollingChannelAdapter extends AbstractMessageSource<java.lang.Object>
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
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, destroy, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
public JpaPollingChannelAdapter(JpaExecutor jpaExecutor)
JpaExecutor
that provide all required JPA
functionality.jpaExecutor
- Must not be null.protected void onInit()
onInit
in class AbstractExpressionEvaluator
protected 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 AbstractMessageSource<java.lang.Object>
public java.lang.String getComponentType()