public class JpaOutboundGateway extends AbstractReplyProducingMessageHandler
OutboundGatewayType
, the outbound gateway
will use either the JpaExecutor
's poll method or its
executeOutboundJpaOperation method.
In order to initialize the adapter, you must provide a JpaExecutor
as
constructor.AbstractReplyProducingMessageHandler.RequestHandler
messagingTemplate
logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
JpaOutboundGateway(JpaExecutor jpaExecutor)
Constructor taking an
JpaExecutor that wraps all JPA Operations. |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected Object |
handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
void |
setGatewayType(OutboundGatewayType gatewayType) |
void |
setProducesReply(boolean producesReply)
If set to 'false', this component will act as an Outbound Channel Adapter.
|
doInvokeAdvisedRequestHandler, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
getOutputChannel, produceOutput, sendOutputs, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public JpaOutboundGateway(JpaExecutor jpaExecutor)
JpaExecutor
that wraps all JPA Operations.jpaExecutor
- Must not be nullpublic String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected void doInit()
doInit
in class AbstractReplyProducingMessageHandler
protected Object handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
handleRequestMessage
in class AbstractReplyProducingMessageHandler
requestMessage
- The request message.null
.public void setGatewayType(OutboundGatewayType gatewayType)
gatewayType
- The gateway type.public void setProducesReply(boolean producesReply)
producesReply
- Defaults to 'true'.