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, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public 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.IntegrationObjectSupport
java.lang.Exception
public 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.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport