org.springframework.integration.jpa.dsl

Class JpaUpdatingOutboundEndpointSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageHandlerSpec<S,JpaOutboundGateway>

org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec<JpaUpdatingOutboundEndpointSpec>

org.springframework.integration.jpa.dsl.JpaUpdatingOutboundEndpointSpec

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<JpaOutboundGateway>, org.springframework.beans.factory.InitializingBean, ComponentsRegistration

public class JpaUpdatingOutboundEndpointSpec
extends JpaBaseOutboundEndpointSpec<JpaUpdatingOutboundEndpointSpec>

A JpaBaseOutboundEndpointSpec extension for the updating JpaOutboundGateway mode. The outbound-channel-adapter is achievable through an internal producesReply option.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec

jpaExecutor

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
JpaUpdatingOutboundEndpointSpec	clearOnFlush(boolean clearOnFlush) If set to true the EntityManager.clear() will be called, and only if the EntityManager.flush() was called after performing persistence operations.
JpaUpdatingOutboundEndpointSpec	flush(boolean flush) If set to true the EntityManager.flush() will be called after persistence operation.
JpaUpdatingOutboundEndpointSpec	flushSize(int flushSize) If the provided value is greater than 0, then EntityManager.flush() will be called after persistence operations as well as within batch operations.
JpaUpdatingOutboundEndpointSpec	persistMode(PersistMode persistMode) Specify a PersistMode for the gateway.

Methods inherited from class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec

entityClass, getComponentsToRegister, jpaQuery, namedQuery, nativeQuery, parameter, parameter, parameter, parameterExpression, parameterExpression, parameterSourceFactory, usePayloadAsParameterSource

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, id, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

persistMode

public JpaUpdatingOutboundEndpointSpec persistMode(PersistMode persistMode)

Specify a PersistMode for the gateway. Defaults to PersistMode.MERGE.

Parameters:

persistMode - the PersistMode to use.

Returns:

the spec

flush

public JpaUpdatingOutboundEndpointSpec flush(boolean flush)

If set to true the EntityManager.flush() will be called after persistence operation. Has the same effect, if the flushSize(int) is specified to 1. For convenience in cases when the provided entity to persist is not an instance of Iterable.

Parameters:

flush - defaults to false.

Returns:

the spec

flushSize

public JpaUpdatingOutboundEndpointSpec flushSize(int flushSize)

If the provided value is greater than 0, then EntityManager.flush() will be called after persistence operations as well as within batch operations. This property has precedence over the flush(boolean), if it is specified to a value greater than 0. If the entity to persist is not an instance of Iterable and this property is greater than 0, then the entity will be flushed as if the flush(boolean) attribute was set to true.

Parameters:

flushSize - defaults to 0.

Returns:

the spec

clearOnFlush

public JpaUpdatingOutboundEndpointSpec clearOnFlush(boolean clearOnFlush)

If set to true the EntityManager.clear() will be called, and only if the EntityManager.flush() was called after performing persistence operations.

Parameters:

clearOnFlush - defaults to false.

Returns:

the spec