public class JpaPollingChannelAdapter
extends org.springframework.integration.context.IntegrationObjectSupport
implements org.springframework.integration.core.MessageSource<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 |
|---|---|
java.lang.String |
getComponentType() |
protected void |
onInit()
Check for mandatory attributes
|
org.springframework.messaging.Message<java.lang.Object> |
receive()
Uses
JpaExecutor.poll() to executes the JPA operation. |
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringpublic JpaPollingChannelAdapter(JpaExecutor jpaExecutor)
JpaExecutor that provide all required JPA
functionality.jpaExecutor - Must not be null.protected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.context.IntegrationObjectSupportjava.lang.Exceptionpublic org.springframework.messaging.Message<java.lang.Object> receive()
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.receive in interface org.springframework.integration.core.MessageSource<java.lang.Object>public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupport