Index

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

C

CACHE_NAME - Static variable in class org.springframework.integration.hazelcast.HazelcastHeaders

The cache name header name.

CacheEventType - Enum Class in org.springframework.integration.hazelcast

Enumeration of Cache Event Types.

cacheLevel(int) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec

Specify the level of caching that this listener container is allowed to apply.

cacheLevel(Integer) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec

Only applies if the JmsMessageChannelSpec.containerType(Class) is a DefaultMessageListenerContainer.

cacheLevel(Integer) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec.ReplyContainerSpec

cacheLevelName(String) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec

Specify the level of caching that this listener container is allowed to apply, in the form of the name of the corresponding constant: e.g.

CacheListeningPolicyType - Enum Class in org.springframework.integration.hazelcast

Enumeration of Cache Listening Policy Type.

CacheRequestHandlerAdvice - Class in org.springframework.integration.handler.advice

The AbstractRequestHandlerAdvice implementation for caching AbstractReplyProducingMessageHandler.RequestHandler#handleRequestMessage(Message) results.

CacheRequestHandlerAdvice(String...) - Constructor for class org.springframework.integration.handler.advice.CacheRequestHandlerAdvice

Create a CacheRequestHandlerAdvice instance based on the provided name of caches and CacheableOperation as default one.

CachingClientConnectionFactory - Class in org.springframework.integration.ip.tcp.connection

Connection factory that caches connections from the underlying target factory.

CachingClientConnectionFactory(AbstractClientConnectionFactory, int) - Constructor for class org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory

Construct a caching connection factory that delegates to the provided factory, with the provided pool size.

CachingSessionFactory<F> - Class in org.springframework.integration.file.remote.session

A SessionFactory implementation that caches Sessions for reuse without requiring reconnection each time the Session is retrieved from the factory.

CachingSessionFactory(SessionFactory<F>) - Constructor for class org.springframework.integration.file.remote.session.CachingSessionFactory

Create a CachingSessionFactory with an unlimited number of sessions.

CachingSessionFactory(SessionFactory<F>, int) - Constructor for class org.springframework.integration.file.remote.session.CachingSessionFactory

Create a CachingSessionFactory with the specified session limit.

CachingSessionFactory.CachedSession - Class in org.springframework.integration.file.remote.session

call() - Method in class org.springframework.integration.hazelcast.leader.LeaderInitiator.LeaderSelector

call() - Method in class org.springframework.integration.support.leader.LockRegistryLeaderInitiator.LeaderSelector

call() - Method in interface org.springframework.integration.util.CheckedCallable

CallerBlocksPolicy - Class in org.springframework.integration.util

A RejectedExecutionHandler that blocks the caller until the executor has room in its queue, or a timeout occurs (in which case a RejectedExecutionException is thrown.

CallerBlocksPolicy(long) - Constructor for class org.springframework.integration.util.CallerBlocksPolicy

Construct instance based on the provided maximum wait time.

Camel - Class in org.springframework.integration.camel.dsl

Factory class for Apache Camel components DSL.

CamelHeaderMapper - Class in org.springframework.integration.camel.support

A HeaderMapper for mapping headers from Spring Integration message to Apache Camel message and back.

CamelHeaderMapper() - Constructor for class org.springframework.integration.camel.support.CamelHeaderMapper

CamelMessageHandler - Class in org.springframework.integration.camel.outbound

A MessageHandler for calling Apache Camel route and produce (optionally) a reply.

CamelMessageHandler() - Constructor for class org.springframework.integration.camel.outbound.CamelMessageHandler

CamelMessageHandler(ProducerTemplate) - Constructor for class org.springframework.integration.camel.outbound.CamelMessageHandler

CamelMessageHandlerSpec - Class in org.springframework.integration.camel.dsl

The MessageHandlerSpec for CamelMessageHandler.

CamelMessageHandlerSpec(ProducerTemplate) - Constructor for class org.springframework.integration.camel.dsl.CamelMessageHandlerSpec

canAdd(Message<?>) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup

This method determines whether messages have been added to this group that supersede the given message based on its sequence id.

canAdd(Message<?>) - Method in interface org.springframework.integration.store.MessageGroup

Query if the message can be added.

canAdd(Message<?>) - Method in class org.springframework.integration.store.SimpleMessageGroup

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.FilterFactoryBean

MessageFilter is an ARPMH.

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.RouterFactoryBean

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

Always returns true - any AbstractMessageProducingHandler can be used directly.

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.SplitterFactoryBean

canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.TransformerFactoryBean

Always returns true - any AbstractMessageProducingHandler can be used directly.

cancelIdleInterval(long) - Method in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec

How often to recycle the idle task (in case of a silently dropped connection).

cancelPing() - Method in class org.springframework.integration.mail.ImapMailReceiver

The hook to be called when we need to cancel the current ping task and close the mail folder.

canConvert(Class<?>, Class<?>) - Method in class org.springframework.integration.util.BeanFactoryTypeConverter

canConvert(TypeDescriptor, TypeDescriptor) - Method in class org.springframework.integration.util.BeanFactoryTypeConverter

Candidate - Interface in org.springframework.integration.leader

Interface that defines the contract for candidates to participate in a leader election.

canRead(Class<?>, MediaType) - Method in class org.springframework.integration.http.converter.MultipartAwareFormHttpMessageConverter

canRead(EvaluationContext, Object, Object) - Method in class org.springframework.integration.json.JsonIndexAccessor

canRead(EvaluationContext, Object, String) - Method in class org.springframework.integration.json.JsonPropertyAccessor

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.ExpressionEvaluatingReleaseStrategy

Evaluate the expression provided on the MessageGroup and return the result (must be boolean).

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.MessageCountReleaseStrategy

Release the group if it has more messages than the threshold and has not previously been released.

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.MethodInvokingReleaseStrategy

canRelease(MessageGroup) - Method in interface org.springframework.integration.aggregator.ReleaseStrategy

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.SequenceSizeReleaseStrategy

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.SimpleSequenceSizeReleaseStrategy

canRelease(MessageGroup) - Method in class org.springframework.integration.aggregator.TimeoutCountSequenceSizeReleaseStrategy

canRelease(MessageGroup) - Method in class org.springframework.integration.file.aggregator.FileAggregator

canRelease(MessageGroup) - Method in class org.springframework.integration.file.aggregator.FileMarkerReleaseStrategy

canWrite(Class<?>, MediaType) - Method in class org.springframework.integration.http.converter.MultipartAwareFormHttpMessageConverter

canWrite(Class<?>, MediaType) - Method in class org.springframework.integration.http.converter.SerializingHttpMessageConverter

canWrite(EvaluationContext, Object, Object) - Method in class org.springframework.integration.json.JsonIndexAccessor

canWrite(EvaluationContext, Object, String) - Method in class org.springframework.integration.json.JsonPropertyAccessor

capacity - Variable in class org.springframework.integration.dsl.QueueChannelSpec

capacity(int) - Method in class org.springframework.integration.dsl.PriorityChannelSpec

capacity(Integer) - Method in class org.springframework.integration.dsl.QueueChannelSpec.MessageStoreSpec

captureReactorContext() - Static method in class org.springframework.integration.util.IntegrationReactiveUtils

Capture a Reactor ContextView from the current thread local state according to the ContextSnapshotFactory logic.

Cassandra - Class in org.springframework.integration.cassandra.dsl

Factory class for Apache Cassandra components DSL.

CassandraMessageHandler - Class in org.springframework.integration.cassandra.outbound

An AbstractReplyProducingMessageHandler implementation for Cassandra outbound operations.

CassandraMessageHandler(ReactiveCassandraOperations) - Constructor for class org.springframework.integration.cassandra.outbound.CassandraMessageHandler

CassandraMessageHandler(ReactiveCassandraOperations, CassandraMessageHandler.Type) - Constructor for class org.springframework.integration.cassandra.outbound.CassandraMessageHandler

CassandraMessageHandler.Type - Enum Class in org.springframework.integration.cassandra.outbound

The mode for the CassandraMessageHandler.

CassandraMessageHandlerSpec - Class in org.springframework.integration.cassandra.dsl

The MessageHandlerSpec for CassandraMessageHandler.

CassandraMessageHandlerSpec(ReactiveCassandraOperations) - Constructor for class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec

CassandraMessageHandlerSpec(ReactiveCassandraOperations, CassandraMessageHandler.Type) - Constructor for class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec

CassandraNamespaceHandler - Class in org.springframework.integration.cassandra.config.xml

The namespace handler for "int-cassandra" namespace.

CassandraNamespaceHandler() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraNamespaceHandler

CassandraOutboundChannelAdapterParser - Class in org.springframework.integration.cassandra.config.xml

The parser for the <int-cassandra:outbound-channel-adapter>.

CassandraOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraOutboundChannelAdapterParser

CassandraOutboundGatewayParser - Class in org.springframework.integration.cassandra.config.xml

The parser for the <int-cassandra:outbound-gateway>.

CassandraOutboundGatewayParser() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraOutboundGatewayParser

CassandraParserUtils - Class in org.springframework.integration.cassandra.config.xml

The int-cassandra namespace XML parser helper.

categories() - Element in annotation interface org.springframework.integration.test.condition.LogLevels

Category names representing Log4j categories to change.

categories(boolean, String...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster

Specify the categories for logging level adjusting configured before.

categories(String...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster

Specify the categories for logging level adjusting configured before.

categoryLevels() - Method in record class org.springframework.integration.test.util.TestUtils.LevelsContainer

Returns the value of the categoryLevels record component.

cause - Variable in class org.springframework.integration.events.IntegrationEvent

cc(String...) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set the cc: addresses.

CC - Static variable in class org.springframework.integration.mail.MailHeaders

ccExpression(String) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set the expression that will be evaluated to determine the cc: addresses.

ccFunction(Function<Message<P>, String[]>) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set a function that will be invoked to determine the cc: addresses based on the message.

chain - Enum constant in enum class org.springframework.integration.IntegrationPatternType

ChainFileListFilter<F> - Class in org.springframework.integration.file.filters

The CompositeFileListFilter extension which chains the result of the previous filter to the next one.

ChainFileListFilter() - Constructor for class org.springframework.integration.file.filters.ChainFileListFilter

ChainFileListFilter(Collection<? extends FileListFilter<F>>) - Constructor for class org.springframework.integration.file.filters.ChainFileListFilter

ChainParser - Class in org.springframework.integration.config.xml

Parser for the <chain> element.

ChainParser() - Constructor for class org.springframework.integration.config.xml.ChainParser

CHANGE_STREAM_OPERATION_TYPE - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders

The header for change stream event type.

CHANGE_STREAM_RESUME_TOKEN - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders

The header for change stream event resume token.

CHANGE_STREAM_TIMESTAMP - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders

The header for change stream event timestamp.

changeStreamInboundChannelAdapter(ReactiveMongoOperations) - Static method in class org.springframework.integration.mongodb.dsl.MongoDb

Create a MongoDbChangeStreamMessageProducerSpec builder instance based on the provided ReactiveMongoOperations.

channel - Variable in class org.springframework.integration.dsl.MessageChannelSpec

channel() - Element in annotation interface org.springframework.integration.annotation.InboundChannelAdapter

channel() - Element in annotation interface org.springframework.integration.annotation.Publisher

channel() - Method in record class org.springframework.integration.channel.DefaultHeaderChannelRegistry.MessageChannelWrapper

Returns the value of the channel record component.

channel(ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms

The factory to produce a JmsMessageChannelSpec.

channel(String) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate a MessageChannelReference instance at the current IntegrationFlow chain position.

channel(String, ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms

The factory to produce a JmsMessageChannelSpec.

channel(String, ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp

Create an initial AmqpMessageChannelSpec.

channel(Function<Channels, MessageChannelSpec<?, ?>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate a MessageChannel instance at the current IntegrationFlow chain position using the Channels factory fluent API.

channel(ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp

Create an initial AmqpMessageChannelSpec.

channel(MessageChannelSpec<?, ?>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate a MessageChannel instance at the current IntegrationFlow chain position using the MessageChannelSpec fluent API.

channel(KafkaTemplate<?, ?>, KafkaListenerContainerFactory<?>, String) - Static method in class org.springframework.integration.kafka.dsl.Kafka

Create a spec for a subscribable channel with the provided parameters.

channel(MessageChannel) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the provided MessageChannel instance at the current IntegrationFlow chain position.

CHANNEL_INITIALIZER_BEAN_NAME - Static variable in class org.springframework.integration.context.IntegrationContextUtils

CHANNEL_RESOLVER_BEAN_NAME - Static variable in class org.springframework.integration.support.channel.ChannelResolverUtils

ChannelInitializer - Class in org.springframework.integration.config

A InitializingBean implementation that is responsible for creating channels that are not explicitly defined but identified via the 'input-channel' attribute of the corresponding endpoints.

ChannelInitializer.AutoCreateCandidatesCollector - Class in org.springframework.integration.config

ChannelInterceptorList(LogAccessor) - Constructor for class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

ChannelInterceptorParser - Class in org.springframework.integration.config.xml

A helper class for parsing the sub-elements of a channel's interceptors element.

ChannelInterceptorParser() - Constructor for class org.springframework.integration.config.xml.ChannelInterceptorParser

channelKeyFallback(boolean) - Method in class org.springframework.integration.dsl.RouterSpec

When true (default), if a resolved channel key does not exist in the channel map, the key itself is used as the channel name, which we will attempt to resolve to a channel.

channelMapping(K, String) - Method in class org.springframework.integration.dsl.RouterSpec

channelMapping(K, MessageChannel) - Method in class org.springframework.integration.dsl.RouterSpec

The router mapping configuration based on the provided generic key and MessageChannel bean.

channelMappings() - Element in annotation interface org.springframework.integration.annotation.Router

The 'key=value' pairs to represent channelMapping entries.

ChannelMessageStore - Interface in org.springframework.integration.store

A marker interface that indicates this message store has optimizations for use in a QueueChannel.

ChannelMessageStorePreparedStatementSetter - Class in org.springframework.integration.jdbc.store.channel

Callback to be used with the JdbcChannelMessageStore.

ChannelMessageStorePreparedStatementSetter() - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter

The default constructor for inheritors who are not interested in the message serialization to byte[].

ChannelMessageStorePreparedStatementSetter(SerializingConverter) - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter

Instantiate a ChannelMessageStorePreparedStatementSetter with the provided serializer and lobHandler, which both must not be null.

ChannelMessageStorePreparedStatementSetter(SerializingConverter, LobHandler) - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter

Deprecated, for removal: This API element is subject to removal in a future version.

since 6.4 (for removal) (if favor of ChannelMessageStorePreparedStatementSetter(SerializingConverter)) with a plain JDBC driver support for byte arrays.

ChannelMessageStoreQueryProvider - Interface in org.springframework.integration.jdbc.store.channel

Common interface used in order to configure the JdbcChannelMessageStore to provide database-specific queries.

channelNameToChannel(String) - Method in class org.springframework.integration.channel.DefaultHeaderChannelRegistry

channelNameToChannel(String) - Method in interface org.springframework.integration.support.channel.HeaderChannelRegistry

Converts the channel name back to a MessageChannel (if it is registered).

ChannelPublishingJmsMessageListener - Class in org.springframework.integration.jms

JMS MessageListener that converts a JMS Message into a Spring Integration Message and sends that Message to a channel.

ChannelPublishingJmsMessageListener() - Constructor for class org.springframework.integration.jms.ChannelPublishingJmsMessageListener

ChannelPurger - Class in org.springframework.integration.channel

A utility class for purging Messages from one or more QueueChannels.

ChannelPurger(QueueChannel...) - Constructor for class org.springframework.integration.channel.ChannelPurger

ChannelPurger(MessageSelector, QueueChannel...) - Constructor for class org.springframework.integration.channel.ChannelPurger

channelResolver(DestinationResolver<MessageChannel>) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

Specify the DestinationResolver strategy to use.

ChannelResolverUtils - Class in org.springframework.integration.support.channel

Channel resolution utilities.

channels - Variable in class org.springframework.integration.channel.DefaultHeaderChannelRegistry

Channels - Class in org.springframework.integration.dsl

CHANNELS_AUTOCREATE - Static variable in class org.springframework.integration.context.IntegrationProperties

Specifies whether to allow create automatically DirectChannel beans for non-declared channels or not.

CHANNELS_MAX_BROADCAST_SUBSCRIBERS - Static variable in class org.springframework.integration.context.IntegrationProperties

Specifies the value for AbstractDispatcher.maxSubscribers in case of point-to-point channels (e.g.

CHANNELS_MAX_UNICAST_SUBSCRIBERS - Static variable in class org.springframework.integration.context.IntegrationProperties

Specifies the value for AbstractDispatcher.maxSubscribers in case of point-to-point channels (e.g.

channelToChannelName(Object) - Method in class org.springframework.integration.channel.DefaultHeaderChannelRegistry

channelToChannelName(Object) - Method in interface org.springframework.integration.support.channel.HeaderChannelRegistry

Converts the channel to a name (String).

channelToChannelName(Object, long) - Method in class org.springframework.integration.channel.DefaultHeaderChannelRegistry

channelToChannelName(Object, long) - Method in interface org.springframework.integration.support.channel.HeaderChannelRegistry

Converts the channel to a name (String).

channelTransacted(boolean) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

channelTransacted(boolean) - Method in class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

Configure channelTransacted on both the RabbitTemplate (for sends) and SimpleMessageListenerContainer (for receives) when using Spring Integration 4.0.

ChannelUtils - Class in org.springframework.integration.channel

Channel utilities.

CHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum

CharacterStreamReadingMessageSource - Class in org.springframework.integration.stream

A pollable source for Readers.

CharacterStreamReadingMessageSource(Reader) - Constructor for class org.springframework.integration.stream.CharacterStreamReadingMessageSource

Construct an instance with the provider reader.

CharacterStreamReadingMessageSource(Reader, int) - Constructor for class org.springframework.integration.stream.CharacterStreamReadingMessageSource

Construct an instance with the provider reader and buffer size.

CharacterStreamReadingMessageSource(Reader, int, boolean) - Constructor for class org.springframework.integration.stream.CharacterStreamReadingMessageSource

Construct an instance with the provided reader and buffer size.

CharacterStreamWritingMessageHandler - Class in org.springframework.integration.stream

A MessageHandler that writes characters to a Writer.

CharacterStreamWritingMessageHandler(Writer) - Constructor for class org.springframework.integration.stream.CharacterStreamWritingMessageHandler

CharacterStreamWritingMessageHandler(Writer, int) - Constructor for class org.springframework.integration.stream.CharacterStreamWritingMessageHandler

charset - Variable in class org.springframework.integration.zip.transformer.AbstractZipTransformer

charset(String) - Method in class org.springframework.integration.file.dsl.FileSplitterSpec

Set the charset to be used when reading the file, when something other than the default charset is required.

charset(String) - Method in class org.springframework.integration.file.dsl.FileTransferringMessageHandlerSpec

Set the charset to use when converting String payloads to bytes as the content of the remote file.

charset(String) - Method in class org.springframework.integration.file.dsl.FileWritingMessageHandlerSpec

Set the charset to use when converting String payloads to bytes as the content of the file.

charset(String) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec

Set the charset to use when converting String payloads to bytes as the content of the remote file.

charset(String) - Method in class org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec

Specify the charset name to use for converting String-typed payloads to bytes.

charset(Charset) - Method in class org.springframework.integration.file.dsl.FileSplitterSpec

Set the charset to be used when reading the file, when something other than the default charset is required.

charset(Charset) - Method in class org.springframework.integration.file.dsl.FileTransferringMessageHandlerSpec

Set the charset to use when converting String payloads to bytes as the content of the remote file.

CHAT - Static variable in class org.springframework.integration.xmpp.XmppHeaders

ChatMessageInboundChannelAdapterParser - Class in org.springframework.integration.xmpp.config

Parser for the XMPP 'inbound-channel-adapter' element.

ChatMessageInboundChannelAdapterParser() - Constructor for class org.springframework.integration.xmpp.config.ChatMessageInboundChannelAdapterParser

ChatMessageListeningEndpoint - Class in org.springframework.integration.xmpp.inbound

This component logs in as a user and forwards any messages to that user on to downstream components.

ChatMessageListeningEndpoint() - Constructor for class org.springframework.integration.xmpp.inbound.ChatMessageListeningEndpoint

ChatMessageListeningEndpoint(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.inbound.ChatMessageListeningEndpoint

ChatMessageOutboundChannelAdapterParser - Class in org.springframework.integration.xmpp.config

Parser for the XMPP 'outbound-channel-adapter' element

ChatMessageOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.xmpp.config.ChatMessageOutboundChannelAdapterParser

ChatMessageSendingMessageHandler - Class in org.springframework.integration.xmpp.outbound

MessageHandler that sends an XMPP Chat Message.

ChatMessageSendingMessageHandler() - Constructor for class org.springframework.integration.xmpp.outbound.ChatMessageSendingMessageHandler

ChatMessageSendingMessageHandler(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.outbound.ChatMessageSendingMessageHandler

checkActive() - Method in class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

checkActive() - Method in class org.springframework.integration.ip.tcp.connection.TcpNioClientConnectionFactory

checkAllowList(Class<?>) - Method in class org.springframework.integration.support.converter.AllowListDeserializingConverter

checkAndConfigureFixedSubscriberChannel(Element, ParserContext, String, String) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

checkClosure(int) - Method in class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer

checkDeliveryMode(Message<?>, MessageProperties, MessageDeliveryMode) - Static method in class org.springframework.integration.amqp.support.MappingUtils

Check the delivery mode and update with the default if not already present.

CheckedCallable<T,E extends Throwable> - Interface in org.springframework.integration.util

A Callable-like interface which allows throwing any Throwable.

CheckedFunction<T,R,E extends Throwable> - Interface in org.springframework.integration.util

A Function-like interface which allows throwing Error.

CheckedRunnable<E extends Throwable> - Interface in org.springframework.integration.util

A Runnable-like interface which allows throwing any Throwable.

checkForIllegalTarget(Object, String) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

checkForIllegalTarget(Object, String) - Method in class org.springframework.integration.config.FilterFactoryBean

checkMessageHandlerAttributes(String, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor

checkReuse(MessageProducer) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

checkTaskExecutor(String) - Method in class org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter

Creates a default task executor if none was supplied.

chmod(int) - Method in class org.springframework.integration.file.dsl.FileTransferringMessageHandlerSpec

Set the file permissions after uploading, e.g.

chmod(int) - Method in class org.springframework.integration.file.dsl.FileWritingMessageHandlerSpec

Set the file permissions after uploading, e.g.

chmod(int) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec

Set the file permissions after uploading, e.g.

CircuitBreakerOpenException(Message<?>, String) - Constructor for exception org.springframework.integration.handler.advice.RequestHandlerCircuitBreakerAdvice.CircuitBreakerOpenException

claim_check_in - Enum constant in enum class org.springframework.integration.IntegrationPatternType

claim_check_out - Enum constant in enum class org.springframework.integration.IntegrationPatternType

claimCheckIn(MessageStore) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore.

claimCheckIn(MessageStore, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore.

ClaimCheckInParser - Class in org.springframework.integration.config.xml

Parser for the <claim-check-in/> element.

ClaimCheckInParser() - Constructor for class org.springframework.integration.config.xml.ClaimCheckInParser

ClaimCheckInTransformer - Class in org.springframework.integration.transformer

Transformer that stores a Message and returns a new Message whose payload is the id of the stored Message.

ClaimCheckInTransformer(MessageStore) - Constructor for class org.springframework.integration.transformer.ClaimCheckInTransformer

Create a claim check-in transformer that will delegate to the provided MessageStore.

claimCheckOut(MessageStore) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore.

claimCheckOut(MessageStore, boolean) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.

claimCheckOut(MessageStore, boolean, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.

ClaimCheckOutParser - Class in org.springframework.integration.config.xml

Parser for the <claim-check-out/> element.

ClaimCheckOutParser() - Constructor for class org.springframework.integration.config.xml.ClaimCheckOutParser

ClaimCheckOutTransformer - Class in org.springframework.integration.transformer

Transformer that accepts a Message whose payload is a UUID and retrieves the Message associated with that id from a MessageStore if available.

ClaimCheckOutTransformer(MessageStore) - Constructor for class org.springframework.integration.transformer.ClaimCheckOutTransformer

Create a claim check-out transformer that will delegate to the provided MessageStore.

classes() - Element in annotation interface org.springframework.integration.test.condition.LogLevels

Classes representing Log4j categories to change.

classes(boolean, Class<?>...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster

Specify the classes for logging level adjusting configured before.

classes(Class<?>...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster

Specify the classes for logging level adjusting configured before.

classLevels() - Method in record class org.springframework.integration.test.util.TestUtils.LevelsContainer

Returns the value of the classLevels record component.

ClassUtils - Class in org.springframework.integration.util

ClassUtils() - Constructor for class org.springframework.integration.util.ClassUtils

clear() - Method in class org.springframework.integration.channel.QueueChannel

clear() - Method in interface org.springframework.integration.channel.QueueChannelOperations

Remove all Messages from this channel.

clear() - Method in class org.springframework.integration.expression.ExpressionEvalMap

clear() - Method in class org.springframework.integration.history.MessageHistory

clear() - Method in interface org.springframework.integration.store.MessageGroup

clear() - Method in class org.springframework.integration.store.SimpleMessageGroup

clear() - Method in class org.springframework.integration.support.MutableMessageHeaders

CLEAR_ALL - Enum constant in enum class org.springframework.integration.hazelcast.CacheEventType

The Hazelcast CLEAR_ALL event.

clearCache() - Method in class org.springframework.integration.expression.ReloadableResourceBundleExpressionSource

Clear the resource bundle cache.

clearFetchedCache() - Method in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource

Clear internal queue of fetched remote files.

clearMessageGroup(Object) - Method in class org.springframework.integration.store.SimpleMessageStore

clearOnFlush(boolean) - Method in class org.springframework.integration.jpa.dsl.JpaUpdatingOutboundEndpointSpec

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

clearQueue() - Method in class org.springframework.integration.redis.inbound.RedisQueueInboundGateway

Clear the Redis Queue specified by RedisQueueInboundGateway.boundListOperations.

clearQueue() - Method in class org.springframework.integration.redis.inbound.RedisQueueMessageDrivenEndpoint

Clear the Redis Queue specified by RedisQueueMessageDrivenEndpoint.boundListOperations.

clearThreadKey() - Method in class org.springframework.integration.file.remote.session.DelegatingSessionFactory

Clear the key for this thread.

clearThreadKey(Message<?>) - Method in class org.springframework.integration.file.remote.session.DelegatingSessionFactory

Messaging-friendly version of DelegatingSessionFactory.clearThreadKey() that can be invoked from a service activator.

CLIENT - Enum constant in enum class org.springframework.integration.hazelcast.ClusterMonitorType

The client listener mode.

CLIENT_ACKNOWLEDGE - Static variable in class org.springframework.integration.jms.util.JmsAdapterUtils

CLIENT_ACKNOWLEDGE_STRING - Static variable in class org.springframework.integration.jms.util.JmsAdapterUtils

CLIENT_MODE - Static variable in class org.springframework.integration.ip.config.IpAdapterParserUtils

ClientCallback<C,T> - Interface in org.springframework.integration.file.remote

RemoteFileTemplate callback with the underlying client instance providing access to lower level methods.

ClientCallbackWithoutResult<C> - Interface in org.springframework.integration.file.remote

RemoteFileTemplate callback with the underlying client instance providing access to lower level methods where no result is returned.

ClientHttpResponseBodyExtractor - Class in org.springframework.integration.webflux.support

The BodyExtractor identity function implementation which just returns the provided ClientHttpResponse.

ClientHttpResponseBodyExtractor() - Constructor for class org.springframework.integration.webflux.support.ClientHttpResponseBodyExtractor

clientId(String) - Method in class org.springframework.integration.jms.dsl.JmsListenerContainerSpec

clientId(String) - Method in class org.springframework.integration.jms.dsl.JmsPublishSubscribeMessageChannelSpec

ClientManager<T,C> - Interface in org.springframework.integration.mqtt.core

A utility abstraction over MQTT client which can be used in any MQTT-related component without need to handle generic client callbacks, reconnects etc.

ClientManager.ConnectCallback - Interface in org.springframework.integration.mqtt.core

A contract for a custom callback on connectComplete event from the client.

clientMode(boolean) - Method in class org.springframework.integration.ip.dsl.TcpInboundChannelAdapterSpec

clientMode(boolean) - Method in class org.springframework.integration.ip.dsl.TcpInboundGatewaySpec

clientMode(boolean) - Method in class org.springframework.integration.ip.dsl.TcpOutboundChannelAdapterSpec

ClientModeCapable - Interface in org.springframework.integration.ip.tcp.connection

Edpoints implementing this interface are capable of running in client-mode.

ClientModeConnectionManager - Class in org.springframework.integration.ip.tcp.connection

Intended to be run on a schedule, simply gets the connection from a client connection factory each time it is run.

ClientModeConnectionManager(AbstractConnectionFactory) - Constructor for class org.springframework.integration.ip.tcp.connection.ClientModeConnectionManager

clientRSocketConnector(ClientRSocketConnector) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec

Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().

ClientRSocketConnector - Class in org.springframework.integration.rsocket

A client AbstractRSocketConnector extension to the RSocket connection.

ClientRSocketConnector(ClientTransport) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector

Instantiate a connector based on the provided ClientTransport.

ClientRSocketConnector(String, int) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector

Instantiate a connector based on the TcpClientTransport.

ClientRSocketConnector(URI) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector

Instantiate a connector based on the WebsocketClientTransport.

ClientStompEncoder - Class in org.springframework.integration.websocket.support

A StompEncoder extension to prepare a message for sending/receiving before/after encoding/decoding when used from WebSockets client side.

ClientStompEncoder() - Constructor for class org.springframework.integration.websocket.support.ClientStompEncoder

ClientWebSocketContainer - Class in org.springframework.integration.websocket

The IntegrationWebSocketContainer implementation for the client Web-Socket connection.

ClientWebSocketContainer(WebSocketClient, String, Object...) - Constructor for class org.springframework.integration.websocket.ClientWebSocketContainer

ClientWebSocketContainer(WebSocketClient, URI) - Constructor for class org.springframework.integration.websocket.ClientWebSocketContainer

Constructor with a prepared URI.

ClientWebSocketContainerParser - Class in org.springframework.integration.websocket.config

The AbstractSingleBeanDefinitionParser implementation for the <websocket:client-container/> element.

ClientWebSocketContainerParser() - Constructor for class org.springframework.integration.websocket.config.ClientWebSocketContainerParser

CLOB - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum

clone() - Method in class org.springframework.integration.history.MessageHistory

cloneAndExecute() - Method in interface org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice.ExecutionCallback

Call this when it is necessary to clone the invocation before calling proceed() - such as when the invocation might be called multiple times - for example in a retry advice.

cloneConnectOptions(MqttConnectOptions) - Static method in class org.springframework.integration.mqtt.support.MqttUtils

Clone the MqttConnectOptions, except the serverUris.

cloneMessageHistoryIfAny() - Method in class org.springframework.integration.support.AbstractIntegrationMessageBuilder

Make a copy of MessageHistory header (if present) for a new message to build.

close() - Method in class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter

close() - Method in class org.springframework.integration.file.filters.CompositeFileListFilter

close() - Method in class org.springframework.integration.file.remote.session.CachingSessionFactory.CachedSession

close() - Method in interface org.springframework.integration.file.remote.session.Session

close() - Method in class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer

close() - Method in class org.springframework.integration.ftp.session.FtpSession

close() - Method in interface org.springframework.integration.ip.tcp.connection.TcpConnection

Closes the connection.

close() - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport

close() - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport

Close this connection.

close() - Method in class org.springframework.integration.ip.tcp.connection.TcpNetConnection

Closes this connection.

close() - Method in class org.springframework.integration.ip.tcp.connection.TcpNioConnection

close() - Method in class org.springframework.integration.ip.tcp.connection.TcpNioSSLConnection

close() - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository

close() - Method in interface org.springframework.integration.jdbc.lock.LockRepository

close() - Method in class org.springframework.integration.metadata.PropertiesPersistingMetadataStore

close() - Method in class org.springframework.integration.sftp.session.SftpSession

close() - Method in class org.springframework.integration.smb.session.SmbSession

close() - Method in class org.springframework.integration.smb.session.SmbShare

close() - Method in interface org.springframework.integration.util.CloseableIterator

close() - Method in class org.springframework.integration.util.FunctionIterator

close() - Method in interface org.springframework.integration.util.Pool

Close the pool; returned items will be destroyed.

close() - Method in class org.springframework.integration.util.SimplePool

CLOSEABLE_RESOURCE - Static variable in class org.springframework.integration.IntegrationMessageHeaderAccessor

CloseableIterator<E> - Interface in org.springframework.integration.util

A CloseableIterator is intended to be used when it may hold resources (such as file or socket handles).

closeConnection(boolean) - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport

If we have been intercepted, propagate the close from the outermost interceptor; otherwise, just call close().

closeConnection(String) - Method in class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

Close a connection with the specified connection id.

closeConnection(String) - Method in class org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory

closeConnection(String) - Method in class org.springframework.integration.ip.tcp.connection.ThreadAffinityClientConnectionFactory

closeFolder() - Method in class org.springframework.integration.mail.AbstractMailReceiver

closeFolder(Folder, boolean) - Static method in class org.springframework.integration.mail.MailTransportUtils

Close the given JavaMail Folder and ignore any thrown exception.

closeService(Service) - Static method in class org.springframework.integration.mail.MailTransportUtils

Close the given JavaMail Service and ignore any thrown exception.

closeSession(WebSocketSession, CloseStatus) - Method in class org.springframework.integration.websocket.IntegrationWebSocketContainer

closeStreamAfterSend(boolean) - Method in class org.springframework.integration.ip.dsl.TcpOutboundGatewaySpec

Set to true to close the connection output stream after sending without closing the connection.

ClusterMonitorType - Enum Class in org.springframework.integration.hazelcast

Enumeration of Hazelcast Cluster Monitor Types.

Codec - Interface in org.springframework.integration.codec

Interface for classes that perform both encode (serialize) and decode (deserialize) on multiple classes.

codecConfigurer(ServerCodecConfigurer) - Method in class org.springframework.integration.webflux.dsl.WebFluxInboundEndpointSpec

CodecMessageConverter - Class in org.springframework.integration.codec

A MessageConverter that delegates to a Codec to convert.

CodecMessageConverter(Codec) - Constructor for class org.springframework.integration.codec.CodecMessageConverter

collection(String) - Method in class org.springframework.integration.mongodb.dsl.MongoDbChangeStreamMessageProducerSpec

Configure a collection to subscribe for change events.

COLLECTION_NAME - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders

The header for MongoDb collection name.

CollectionArgumentResolver - Class in org.springframework.integration.handler.support

A HandlerMethodArgumentResolver implementation for Collection, Iterator or array MethodParameter.

CollectionArgumentResolver(boolean) - Constructor for class org.springframework.integration.handler.support.CollectionArgumentResolver

collectionCallback(MessageCollectionCallback<P>) - Method in class org.springframework.integration.mongodb.dsl.MongoDbOutboundGatewaySpec

Reference to an instance of MessageCollectionCallback which specifies the database operation to execute in the request message context.

CollectionFilter<T> - Interface in org.springframework.integration.util

Base strategy for filtering out a subset of a Collection of elements.

collectionName - Variable in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

collectionName(String) - Method in class org.springframework.integration.mongodb.dsl.AbstractMongoDbMessageSourceSpec

Configure a collection name to query against.

collectionName(String) - Method in class org.springframework.integration.mongodb.dsl.MongoDbOutboundGatewaySpec

Identify the name of the MongoDb collection to use.

collectionName(String) - Method in class org.springframework.integration.mongodb.dsl.ReactiveMongoDbMessageHandlerSpec

Configure a collection name to store data.

collectionNameExpression(String) - Method in class org.springframework.integration.mongodb.dsl.AbstractMongoDbMessageSourceSpec

Configure a SpEL expression to evaluation a collection name on each receive() call.

collectionNameExpression(String) - Method in class org.springframework.integration.mongodb.dsl.MongoDbOutboundGatewaySpec

A SpEL expression which should resolve to a String value identifying the name of the MongoDb collection to use.

collectionNameExpression(Expression) - Method in class org.springframework.integration.mongodb.dsl.AbstractMongoDbMessageSourceSpec

Configure a SpEL expression to evaluation a collection name on each receive() call.

collectionNameExpression(Expression) - Method in class org.springframework.integration.mongodb.dsl.ReactiveMongoDbMessageHandlerSpec

Configure a SpEL expression to evaluate a collection name against a request message.

collectionNameFunction(Function<Message<P>, String>) - Method in class org.springframework.integration.mongodb.dsl.MongoDbOutboundGatewaySpec

A Function which should resolve to a String (e.q., collectionNameFunction(Message::getPayload)).

collectionNameFunction(Function<Message<P>, String>) - Method in class org.springframework.integration.mongodb.dsl.ReactiveMongoDbMessageHandlerSpec

Configure a Function for evaluation a collection against request message.

collectionNameSupplier(Supplier<String>) - Method in class org.springframework.integration.mongodb.dsl.AbstractMongoDbMessageSourceSpec

Configure a Supplier to obtain a collection name on each receive() call.

command() - Method in record class org.springframework.integration.http.management.ControlBusController.ControlBusCommand

Returns the value of the command record component.

COMMAND - Static variable in class org.springframework.integration.redis.support.RedisHeaders

CommandArgument(String, Class<?>) - Constructor for record class org.springframework.integration.http.management.ControlBusController.CommandArgument

Creates an instance of a CommandArgument record class.

commands() - Method in record class org.springframework.integration.http.management.ControlBusController.ControlBusBean

Returns the value of the commands record component.

commitCallback(OffsetCommitCallback) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Set the commit callback; by default a simple logging callback is used to log success at DEBUG level and failures at ERROR level.

commonOutboundProperties(Element, ParserContext, BeanDefinitionBuilder) - Static method in class org.springframework.integration.kafka.config.xml.KafkaParsingUtils

CommonSocketOptions - Interface in org.springframework.integration.ip

comparator(Comparator<Message<?>>) - Method in class org.springframework.integration.dsl.PriorityChannelSpec

compare(Message<?>, Message<?>) - Method in class org.springframework.integration.aggregator.MessageSequenceComparator

compareTo(FileInfo<F>) - Method in class org.springframework.integration.file.remote.AbstractFileInfo

compareTo(KafkaMessageSource.KafkaAckInfo<K, V>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckInfoImpl

compareValues(BiPredicate<String, String>) - Method in class org.springframework.integration.selector.MetadataStoreSelector

Fluent version of MetadataStoreSelector.setCompareValues(BiPredicate).

compilerMode() - Element in annotation interface org.springframework.integration.annotation.UseSpelInvoker

Specify that the annotated method (or methods in the annotated class) will be invoked using SpEL instead of an InvocableHandlerMethod with the specified compilerMode.

complete() - Method in interface org.springframework.integration.store.MessageGroup

Complete the group.

complete() - Method in class org.springframework.integration.store.MessageGroupMetadata

complete() - Method in class org.springframework.integration.store.SimpleMessageGroup

COMPLETE - Static variable in class org.springframework.integration.mongodb.store.MessageDocumentFields

completeGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore

completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore

completeGroup(Object) - Method in class org.springframework.integration.store.AbstractKeyValueMessageStore

completeGroup(Object) - Method in interface org.springframework.integration.store.MessageGroupStore

Completes this MessageGroup.

completeGroup(Object) - Method in class org.springframework.integration.store.SimpleMessageStore

completeGroup(Object, MessageGroup, Lock) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

completeGroup(Message<?>, Object, MessageGroup, Lock) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.GatewayTags

Name of the message gateway component.

COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.HandlerTags

Name of the message handler component.

COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.ProducerTags

Name of the message handler component.

COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.GatewayTags

Type of the component - 'gateway'.

COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.HandlerTags

Type of the component - 'handler'.

COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.ProducerTags

Type of the component - 'producer'.

ComponentsEvaluationCallback(EvaluationContext, Object, boolean, Class<?>) - Constructor for class org.springframework.integration.expression.ExpressionEvalMap.ComponentsEvaluationCallback

ComponentSourceAware - Interface in org.springframework.integration.context

The contract to supply and provide useful information about a bean definition (or singleton) source - the place where this bean is declared.

ComponentsRegistration - Interface in org.springframework.integration.dsl

The marker interface for the IntegrationComponentSpec implementation, when there is need to register as beans not only the target spec's components, but some additional components, e.g.

componentsToRegister - Variable in class org.springframework.integration.dsl.EndpointSpec

componentsToRegister - Variable in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec

CompositeCodec - Class in org.springframework.integration.codec

A Codec that can delegate to one out of many Codecs, each mapped to a class.

CompositeCodec(Map<Class<?>, Codec>, Codec) - Constructor for class org.springframework.integration.codec.CompositeCodec

CompositeCodec(Codec) - Constructor for class org.springframework.integration.codec.CompositeCodec

CompositeExecutor - Class in org.springframework.integration.util

An Executor that encapsulates two underlying executors.

CompositeExecutor(Executor, Executor) - Constructor for class org.springframework.integration.util.CompositeExecutor

CompositeFileListFilter<F> - Class in org.springframework.integration.file.filters

Simple FileListFilter that predicates its matches against all of the configured FileListFilter.

CompositeFileListFilter() - Constructor for class org.springframework.integration.file.filters.CompositeFileListFilter

CompositeFileListFilter(Collection<? extends FileListFilter<F>>) - Constructor for class org.springframework.integration.file.filters.CompositeFileListFilter

CompositeKryoRegistrar - Class in org.springframework.integration.codec.kryo

A KryoRegistrar that delegates and validates registrations across all components.

CompositeKryoRegistrar(List<KryoRegistrar>) - Constructor for class org.springframework.integration.codec.kryo.CompositeKryoRegistrar

CompositeMessageHandler - Interface in org.springframework.integration.handler

Classes implementing this interface delegate to a list of handlers.

CompositeMessageHandlerNode - Class in org.springframework.integration.graph

Represents a composite message handler.

CompositeMessageHandlerNode(int, String, MessageHandler, String, String, List<CompositeMessageHandlerNode.InnerHandler>) - Constructor for class org.springframework.integration.graph.CompositeMessageHandlerNode

CompositeMessageHandlerNode.InnerHandler - Class in org.springframework.integration.graph

CompoundTrigger - Class in org.springframework.integration.util

A Trigger that delegates the Trigger.nextExecutionTime(TriggerContext) to one of two Triggers.

CompoundTrigger(Trigger) - Constructor for class org.springframework.integration.util.CompoundTrigger

Construct a compound trigger with the supplied primary trigger.

CompoundTriggerAdvice - Class in org.springframework.integration.aop

A MessageSourceMutator that uses a CompoundTrigger to adjust the poller - when a message is present, the compound trigger's primary trigger is used to determine the next poll.

CompoundTriggerAdvice(CompoundTrigger, Trigger) - Constructor for class org.springframework.integration.aop.CompoundTriggerAdvice

concurrency(int) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Specify a concurrency maximum number for the AbstractMessageListenerContainer.

concurrency(String) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec

The concurrency to use.

concurrentConsumers(int) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

concurrentConsumers(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec

concurrentConsumers(int) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec

The concurrent consumers number to use.

concurrentConsumers(int) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec

Only applies if the JmsMessageChannelSpec.containerType(Class) is a DefaultMessageListenerContainer or a SimpleMessageListenerContainer.

concurrentConsumers(Integer) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec.ReplyContainerSpec

ConcurrentMetadataStore - Interface in org.springframework.integration.metadata

Supports atomic updates to values in the store.

ConcurrentSftpClient(ClientSession, SftpVersionSelector, SftpErrorDataHandler) - Constructor for class org.springframework.integration.sftp.session.DefaultSftpSessionFactory.ConcurrentSftpClient

ConfigurableCompositeMessageConverter - Class in org.springframework.integration.support.converter

A CompositeMessageConverter extension with some default MessageConverters which can be overridden with the given converters or added in the end of target converters collection.

ConfigurableCompositeMessageConverter() - Constructor for class org.springframework.integration.support.converter.ConfigurableCompositeMessageConverter

Create an instance with the default converters.

ConfigurableCompositeMessageConverter(Collection<MessageConverter>) - Constructor for class org.springframework.integration.support.converter.ConfigurableCompositeMessageConverter

Create an instance with the given converters and without defaults.

ConfigurableCompositeMessageConverter(Collection<MessageConverter>, boolean) - Constructor for class org.springframework.integration.support.converter.ConfigurableCompositeMessageConverter

Create an instance with the given converters and with defaults in the end.

ConfigurableMongoDbMessageStore - Class in org.springframework.integration.mongodb.store

An alternate MongoDB MessageStore and MessageGroupStore which allows the user to configure the instance of MongoTemplate.

ConfigurableMongoDbMessageStore(MongoTemplate) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

ConfigurableMongoDbMessageStore(MongoTemplate, String) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

ConfigurableMongoDbMessageStore(MongoDatabaseFactory) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

ConfigurableMongoDbMessageStore(MongoDatabaseFactory, String) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

ConfigurableMongoDbMessageStore(MongoDatabaseFactory, MappingMongoConverter) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

ConfigurableMongoDbMessageStore(MongoDatabaseFactory, MappingMongoConverter, String) - Constructor for class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

configure(DatagramSocket) - Method in interface org.springframework.integration.ip.udp.SocketCustomizer

Configure the socket ({code setTrafficClass()}, etc).

configure(Consumer<StreamListenerContainer>) - Method in class org.springframework.integration.amqp.dsl.RabbitStreamMessageListenerContainerSpec

Perform additional configuration of the container.

configure(IntegrationFlowDefinition<?>) - Method in interface org.springframework.integration.dsl.IntegrationFlow

The callback-based function to declare the chain of EIP-methods to configure an integration flow with the provided IntegrationFlowDefinition.

configure(IntegrationFlowDefinition<?>) - Method in class org.springframework.integration.dsl.IntegrationFlowAdapter

configure(IntegrationFlowDefinition<?>) - Method in class org.springframework.integration.dsl.StandardIntegrationFlow

configureAdviceChain(Element, Element, boolean, BeanDefinition, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureAdviceChain(Element, Element, BeanDefinition, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureAndSetAdviceChainIfPresent(Element, Element, boolean, BeanDefinition, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureAndSetAdviceChainIfPresent(Element, Element, boolean, BeanDefinition, ParserContext, String) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureAndSetAdviceChainIfPresent(Element, Element, BeanDefinition, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureAndSetAdviceChainIfPresent(Element, Element, BeanDefinition, ParserContext, String) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

configureChannels(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.amqp.config.AmqpInboundChannelAdapterParser

configureChannels(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.amqp.config.AmqpInboundGatewayParser

configureContainer(Consumer<DirectMessageListenerContainerSpec>) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterDMLCSpec

configureContainer(Consumer<DirectMessageListenerContainerSpec>) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundGatewayDMLCSpec

configureContainer(Consumer<RabbitStreamMessageListenerContainerSpec>) - Method in class org.springframework.integration.amqp.dsl.RabbitStreamInboundChannelAdapterSpec

configureContainer(Consumer<SimpleMessageListenerContainerSpec>) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSMLCSpec

configureContainer(Consumer<SimpleMessageListenerContainerSpec>) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundGatewaySMLCSpec

configureFilter(BeanDefinitionBuilder, Element, ParserContext, String, String, String) - Method in class org.springframework.integration.file.config.AbstractRemoteFileOutboundGatewayParser

configureHandler(ServiceActivatingHandler) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

configureHeaderMapper(Element, BeanDefinitionBuilder, ParserContext, Class<?>, String) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Utility method to configure a HeaderMapper for Inbound and Outbound channel adapters/gateway.

configureHeaderMapper(Element, BeanDefinitionBuilder, ParserContext, BeanDefinitionBuilder, String) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Utility method to configure a HeaderMapper for Inbound and Outbound channel adapters/gateway.

configureJmsTemplate(Consumer<JmsTemplateSpec>) - Method in class org.springframework.integration.jms.dsl.JmsInboundChannelAdapterSpec.JmsInboundChannelSpecTemplateAware

Configure the channel adapter to use the template specification created by invoking the Consumer callback, passing in a JmsTemplateSpec.

configureJmsTemplate(Consumer<JmsTemplateSpec>) - Method in class org.springframework.integration.jms.dsl.JmsOutboundChannelAdapterSpec.JmsOutboundChannelSpecTemplateAware

configureKafkaTemplate(Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>>) - Method in class org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec

Configure a Kafka Template by invoking the Consumer callback, with a KafkaTemplateSpec argument.

configureKafkaTemplate(Consumer<KafkaTemplateSpec<K, V>>) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec

Configure a Kafka Template by invoking the Consumer callback, with a KafkaTemplateSpec argument.

configureKryoInstance(Kryo) - Method in class org.springframework.integration.codec.kryo.AbstractKryoCodec

Subclasses implement this to configure the kryo instance.

configureKryoInstance(Kryo) - Method in class org.springframework.integration.codec.kryo.PojoCodec

configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K, V>>) - Method in class org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec

Configure a listener container by invoking the Consumer callback, with a KafkaMessageListenerContainerSpec argument.

configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K, V>>) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec

Configure a listener container by invoking the Consumer callback, with a KafkaMessageListenerContainerSpec argument.

configureListenerContainer(Consumer<S>) - Method in class org.springframework.integration.jms.dsl.JmsInboundGatewaySpec.JmsInboundGatewayListenerContainerSpec

Specify a Consumer to accept a JmsListenerContainerSpec for further configuration.

configureListenerContainer(Consumer<S>) - Method in class org.springframework.integration.jms.dsl.JmsMessageDrivenChannelAdapterSpec.JmsMessageDrivenChannelAdapterListenerContainerSpec

Configure a listener container by invoking the Consumer callback, with a JmsListenerContainerSpec argument.

configureMappingRouter(AbstractMappingMessageRouter) - Method in class org.springframework.integration.config.RouterFactoryBean

configurePollerMetadata(Element, BeanDefinitionBuilder, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Parse a "poller" element to provide a reference for the target BeanDefinitionBuilder.

configurePollingEndpoint(AbstractPollingEndpoint, Poller) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor

configureRouter(AbstractMessageRouter) - Method in class org.springframework.integration.config.RouterFactoryBean

configureSocket(SocketCustomizer) - Method in class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

Configure the socket.

configureSocket(SocketCustomizer) - Method in class org.springframework.integration.ip.dsl.UdpInboundChannelAdapterSpec

Configure the socket.

configureSource(MessageSource<?>) - Method in class org.springframework.integration.file.remote.aop.StandardRotationPolicy

configureSplitter(AbstractMessageSplitter) - Method in class org.springframework.integration.config.SplitterFactoryBean

configureTemplate(Consumer<KafkaTemplateSpec<K, R>>) - Method in class org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec

Configure a template by invoking the Consumer callback, with a KafkaTemplateSpec argument.

configureTransactionAttributes(Element) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Parse a "transactional" element and configure a TransactionInterceptor with "transactionManager" and other "transactionDefinition" properties.

configureTransactionAttributes(Element, boolean) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Parse a "transactional" element and configure a TransactionInterceptor or TransactionHandleMessageAdvice with "transactionManager" and other "transactionDefinition" properties.

configureTransactionDefinition(Element) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Parse attributes of "transactional" element and configure a DefaultTransactionAttribute with provided "transactionDefinition" properties.

confirm(CorrelationData, boolean, String) - Method in class org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint

confirmAckChannel(MessageChannel) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set the channel to which acks are send (publisher confirms).

confirmCorrelationExpression(String) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set a SpEL expression to evaluate confirm correlation at runtime.

confirmCorrelationExpression(Expression) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set a SpEL expression to evaluate confirm correlation at runtime.

confirmCorrelationFunction(Function<Message<?>, Object>) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set a Function to evaluate confirm correlation at runtime.

confirmNackChannel(MessageChannel) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set the channel to which nacks are send (publisher confirms).

confirmTimeout(long) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

Set a timeout after which a nack will be synthesized if no publisher confirm has been received within that time.

confirmTimeout(long) - Method in class org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec

Set a timeout for the confirm result.

connect() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector

Perform subscription into the RSocket server for incoming requests.

connect(StompSessionHandler) - Method in class org.springframework.integration.stomp.AbstractStompSessionManager

connect(StompSessionHandler) - Method in interface org.springframework.integration.stomp.StompSessionManager

CONNECT_TIMEOUT - Static variable in class org.springframework.integration.ip.config.IpAdapterParserUtils

connectComplete(boolean) - Method in interface org.springframework.integration.mqtt.core.ClientManager.ConnectCallback

Called when the connection to the server is completed successfully.

connectComplete(boolean) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter

connectComplete(boolean) - Method in class org.springframework.integration.mqtt.inbound.Mqttv5PahoMessageDrivenChannelAdapter

connectComplete(boolean, String) - Method in class org.springframework.integration.mqtt.core.Mqttv3ClientManager

connectComplete(boolean, String) - Method in class org.springframework.integration.mqtt.core.Mqttv5ClientManager

connectComplete(boolean, String) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter

connectComplete(boolean, String) - Method in class org.springframework.integration.mqtt.inbound.Mqttv5PahoMessageDrivenChannelAdapter

connectComplete(boolean, String) - Method in class org.springframework.integration.mqtt.outbound.Mqttv5PahoMessageHandler

CONNECTION_ID - Static variable in class org.springframework.integration.ip.IpHeaders

A unique identifier for a TCP connection; set by the framework for inbound messages; when sending to a server-side inbound channel adapter, or replying to an inbound gateway, this header is required so the endpoint can determine which connection to send the message to.

connectionFactory - Variable in class org.springframework.integration.ip.dsl.TcpInboundChannelAdapterSpec

connectionFactory - Variable in class org.springframework.integration.ip.dsl.TcpInboundGatewaySpec

connectionFactory - Variable in class org.springframework.integration.ip.dsl.TcpOutboundChannelAdapterSpec

connectionFactory - Variable in class org.springframework.integration.ip.dsl.TcpOutboundGatewaySpec

connectionFactory(ConnectionFactory) - Method in class org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec

ConnectionFactory - Interface in org.springframework.integration.ip.tcp.connection

A factory used to create TcpConnection objects.

connectionLost(Throwable) - Method in class org.springframework.integration.mqtt.core.Mqttv3ClientManager

connectionLost(Throwable) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter

connectionLost(Throwable) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler

connections - Variable in class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

connectionsMonitor - Variable in class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

connectionSupport(TcpNetConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNetClientConnectionFactorySpec

The TcpNetConnectionSupport to use to create connection objects.

connectionSupport(TcpNetConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNetServerConnectionFactorySpec

The TcpNetConnectionSupport to use to create connection objects.

connectionSupport(TcpNioConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNioClientConnectionFactorySpec

The TcpNioConnectionSupport to use.

connectionSupport(TcpNioConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNioServerConnectionFactorySpec

The TcpNioConnectionSupport to use.

connectTimeout(int) - Method in class org.springframework.integration.ip.dsl.TcpClientConnectionFactorySpec

Set the connection timeout in seconds.

connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec

Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.

connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec

Configure an URL for ZMQ.Socket.connect(String).

consecutiveActiveTrigger(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec

consecutiveIdleTrigger(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec

ConsoleInboundChannelAdapterParser - Class in org.springframework.integration.stream.config

Parser for the <stdin-channel-adapter> element.

ConsoleInboundChannelAdapterParser() - Constructor for class org.springframework.integration.stream.config.ConsoleInboundChannelAdapterParser

ConsoleOutboundChannelAdapterParser - Class in org.springframework.integration.stream.config

Parser for the "stdout-" and "stderr-channel-adapter" elements.

ConsoleOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.stream.config.ConsoleOutboundChannelAdapterParser

CONSOLIDATED_HEADERS - Static variable in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter

Header containing List<Map<String, Object> headers when batch mode is AmqpInboundChannelAdapter.BatchMode.EXTRACT_PAYLOADS_WITH_HEADERS.

constructType(Type) - Method in class org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper

constructType(Type) - Method in class org.springframework.integration.support.json.Jackson2JsonObjectMapper

consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec

Specify a Duration to delay consumption when no data received.

consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec

Specify a Duration to delay consumption when no data received.

CONSUMER - Static variable in class org.springframework.integration.redis.support.RedisHeaders

CONSUMER_GROUP - Static variable in class org.springframework.integration.redis.support.RedisHeaders

consumerArguments(Map<String, Object>) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

Set consumer arguments.

consumerBatchEnabled(boolean) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec

Set to true to enable batching of consumed messages.

consumerCustomizer(ConsumerCustomizer) - Method in class org.springframework.integration.amqp.dsl.RabbitStreamMessageListenerContainerSpec

Set a consumer customizer.

ConsumerEndpointFactoryBean - Class in org.springframework.integration.config

The FactoryBean implementation for AbstractEndpoint population.

ConsumerEndpointFactoryBean() - Constructor for class org.springframework.integration.config.ConsumerEndpointFactoryBean

ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends MessageHandler> - Class in org.springframework.integration.dsl

A EndpointSpec for consumer endpoints.

ConsumerEndpointSpec(H) - Constructor for class org.springframework.integration.dsl.ConsumerEndpointSpec

consumerProperties() - Method in record class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory

Returns the value of the consumerProperties record component.

consumerRebalanceListener(ConsumerRebalanceListener) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Set the user defined ConsumerRebalanceListener implementation.

consumersPerQueue(int) - Method in class org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec

consumerTagStrategy(ConsumerTagStrategy) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

Set the implementation of ConsumerTagStrategy to generate consumer tags.

consumes(String...) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec.RequestMappingSpec

The consumable media types of the mapped request, narrowing the primary mapping.

container(ConnectionFactory, Destination) - Static method in class org.springframework.integration.jms.dsl.Jms

The factory to produce a JmsListenerContainerSpec.

container(ConnectionFactory, String) - Static method in class org.springframework.integration.jms.dsl.Jms

The factory to produce a JmsListenerContainerSpec.

containerType(Class<? extends AbstractMessageListenerContainer>) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec

Configure the type of the container.

contains(Object) - Method in class org.springframework.integration.history.MessageHistory

containsAll(Collection<?>) - Method in class org.springframework.integration.history.MessageHistory

containsElementIgnoreCase(String[], String) - Static method in class org.springframework.integration.http.support.DefaultHttpHeaderMapper

containsKey(Object) - Method in class org.springframework.integration.expression.ExpressionEvalMap

containsSequence(Integer) - Method in class org.springframework.integration.store.SimpleMessageGroup

Return true if a message with this sequence number header exists in the group.

containsValue(Object) - Method in class org.springframework.integration.expression.ExpressionEvalMap

content_enricher - Enum constant in enum class org.springframework.integration.IntegrationPatternType

CONTENT_MD5 - Static variable in class org.springframework.integration.http.support.DefaultHttpHeaderMapper

CONTENT_TYPE - Static variable in class org.springframework.integration.mail.MailHeaders

CONTENT_TYPE_ID - Static variable in class org.springframework.integration.mapping.support.JsonHeaders

CONTENT_TYPE_PROPERTY - Static variable in class org.springframework.integration.jms.JmsHeaderMapper

ContentBasedHeaderMatcher(boolean, Collection<String>) - Constructor for class org.springframework.integration.mapping.AbstractHeaderMapper.ContentBasedHeaderMatcher

ContentEnricher - Class in org.springframework.integration.transformer

Content Enricher is a Message Transformer that can augment a message's payload with either static values or by optionally invoking a downstream message flow via its request channel and then applying values from the reply Message to the original payload.

ContentEnricher() - Constructor for class org.springframework.integration.transformer.ContentEnricher

contentType(String) - Method in class org.springframework.integration.debezium.dsl.DebeziumMessageProducerSpec

Set the outbound message content type.

contentType(String) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set the content type.

contentTypeExpression(String) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set an expression that will be evaluated to determine the content type.

contentTypeFunction(Function<Message<P>, String>) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder

Set a function that will be invoked to determine the content type.

context - Variable in class org.springframework.integration.hazelcast.leader.LeaderInitiator.LeaderSelector

Context - Interface in org.springframework.integration.leader

Interface that defines the context for candidate leadership.

CONTEXT_ACKNOWLEDGMENT - Static variable in interface org.springframework.integration.kafka.inbound.KafkaInboundEndpoint

RetryContext attribute key for an acknowledgment if the listener is capable of acknowledging.

CONTEXT_CONSUMER - Static variable in interface org.springframework.integration.kafka.inbound.KafkaInboundEndpoint

RetryContext attribute key for the consumer if the listener is consumer-aware.

CONTEXT_RECORD - Static variable in interface org.springframework.integration.kafka.inbound.KafkaInboundEndpoint

RetryContext attribute key for the record.

contextClearHook - Variable in class org.springframework.integration.handler.advice.ContextHolderRequestHandlerAdvice

ContextHolderRequestHandlerAdvice - Class in org.springframework.integration.handler.advice

An AbstractRequestHandlerAdvice implementation to store and reset a value into/from some context (e.g.

ContextHolderRequestHandlerAdvice(Function<Message<?>, Object>, Consumer<Object>, Runnable) - Constructor for class org.springframework.integration.handler.advice.ContextHolderRequestHandlerAdvice

Construct an instance based on the provided hooks.

contextSetHook - Variable in class org.springframework.integration.handler.advice.ContextHolderRequestHandlerAdvice

ContinuationHandlerMethodArgumentResolver - Class in org.springframework.integration.handler.support

No-op resolver for method arguments of type Continuation.

ContinuationHandlerMethodArgumentResolver() - Constructor for class org.springframework.integration.handler.support.ContinuationHandlerMethodArgumentResolver

control_bus - Enum constant in enum class org.springframework.integration.IntegrationPatternType

CONTROL_BUS_ARGUMENTS - Static variable in class org.springframework.integration.IntegrationMessageHeaderAccessor

The header for Control Bus command arguments.

CONTROL_BUS_COMMAND_REGISTRY_BEAN_NAME - Static variable in class org.springframework.integration.context.IntegrationContextUtils

controlBus() - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Deprecated.

in favor of BaseIntegrationFlowDefinition.controlBusOnRegistry() - will be restored in next version.

controlBus(Consumer<GenericEndpointSpec<ServiceActivatingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Deprecated.

in favor of BaseIntegrationFlowDefinition.controlBusOnRegistry(Consumer) - will be restored in next version.

ControlBusBean(String, List<ControlBusController.ControlBusCommand>) - Constructor for record class org.springframework.integration.http.management.ControlBusController.ControlBusBean

Creates an instance of a ControlBusBean record class.

ControlBusCommand(String, String, List<Class<?>>) - Constructor for record class org.springframework.integration.http.management.ControlBusController.ControlBusCommand

Creates an instance of a ControlBusCommand record class.

ControlBusCommandRegistry - Class in org.springframework.integration.support.management

A global component to serve Control Bus command and respective SpEL expression relationships.

ControlBusCommandRegistry() - Constructor for class org.springframework.integration.support.management.ControlBusCommandRegistry

ControlBusCommandRegistry.CommandMethod - Class in org.springframework.integration.support.management

The Java Bean to represent a Control Bus command as a bean method with its parameter types.

ControlBusController - Class in org.springframework.integration.http.management

The REST Controller to provide the management API for Control Bus pattern.

ControlBusController(ControlBusCommandRegistry, FormattingConversionService) - Constructor for class org.springframework.integration.http.management.ControlBusController

ControlBusController.CommandArgument - Record Class in org.springframework.integration.http.management

ControlBusController.ControlBusBean - Record Class in org.springframework.integration.http.management

ControlBusController.ControlBusCommand - Record Class in org.springframework.integration.http.management

ControlBusControllerConfiguration - Class in org.springframework.integration.http.config

Registers the ControlBusController bean.

ControlBusControllerConfiguration() - Constructor for class org.springframework.integration.http.config.ControlBusControllerConfiguration

ControlBusFactoryBean - Class in org.springframework.integration.config

FactoryBean for creating MessageHandler instances to handle a message with a Control Bus command.

ControlBusFactoryBean() - Constructor for class org.springframework.integration.config.ControlBusFactoryBean

ControlBusMessageProcessor - Class in org.springframework.integration.handler

A MessageProcessor implementation that expects a Control Bus command as a request message.

ControlBusMessageProcessor() - Constructor for class org.springframework.integration.handler.ControlBusMessageProcessor

ControlBusMessageProcessor(ControlBusCommandRegistry) - Constructor for class org.springframework.integration.handler.ControlBusMessageProcessor

Create an instance based on the provided ControlBusCommandRegistry.

ControlBusMethodFilter - Class in org.springframework.integration.expression

Deprecated, for removal: This API element is subject to removal in a future version.

in favor of ControlBusMethodFilter

ControlBusMethodFilter - Class in org.springframework.integration.support.management

The ReflectionUtils.MethodFilter to restrict method invocations to: Pausable or Lifecycle components get, set and shutdown methods of CustomizableThreadCreator methods with ManagedAttribute or ManagedOperation annotations

ControlBusMethodFilter() - Constructor for class org.springframework.integration.expression.ControlBusMethodFilter

Deprecated.

ControlBusMethodFilter() - Constructor for class org.springframework.integration.support.management.ControlBusMethodFilter

controlBusOnRegistry() - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the Control Bus EI Pattern specific MessageHandler implementation at the current IntegrationFlow chain position.

controlBusOnRegistry(Consumer<GenericEndpointSpec<ServiceActivatingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the Control Bus EI Pattern specific MessageHandler implementation at the current IntegrationFlow chain position.

ControlBusParser - Class in org.springframework.integration.config.xml

ControlBusParser() - Constructor for class org.springframework.integration.config.xml.ControlBusParser

convert(byte[]) - Method in class org.springframework.integration.support.converter.AllowListDeserializingConverter

convert(JsonNode, DeserializationContext) - Method in class org.springframework.integration.support.json.MessageJacksonDeserializer

convert(Class<P>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime.

convert(Class<P>, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime.

convert(Object) - Method in class org.springframework.integration.util.UUIDConverter

Convert the input to a UUID using the convenience method UUIDConverter.getUUID(Object).

convert(Object, TypeDescriptor, TypeDescriptor) - Method in class org.springframework.integration.json.JsonNodeWrapperToJsonNodeConverter

convert(MBeanServerConnection, ObjectInstance) - Method in class org.springframework.integration.jmx.DefaultMBeanObjectConverter

convert(MBeanServerConnection, ObjectInstance) - Method in interface org.springframework.integration.jmx.MBeanObjectConverter

convert(Binary) - Method in class org.springframework.integration.mongodb.support.BinaryToMessageConverter

convert(Message<?>) - Method in class org.springframework.integration.mongodb.support.MessageToBinaryConverter

convertAndSend(Message<?>) - Method in class org.springframework.integration.ip.udp.MulticastSendingMessageHandler

convertAndSend(Message<?>) - Method in class org.springframework.integration.ip.udp.UnicastSendingMessageHandler

convertAndSend(Message<?>) - Method in class org.springframework.integration.syslog.inbound.SyslogReceivingChannelAdapterSupport

converter - Variable in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

converter(Converter<T, U>) - Static method in class org.springframework.integration.dsl.Transformers

CONVERTER_REGISTRAR_BEAN_NAME - Static variable in class org.springframework.integration.context.IntegrationContextUtils

ConverterParser - Class in org.springframework.integration.config.xml

ConverterParser() - Constructor for class org.springframework.integration.config.xml.ConverterParser

convertExceptions(boolean) - Method in class org.springframework.integration.http.dsl.HttpRequestHandlerEndpointSpec

Flag to determine if conversion and writing out of message handling exceptions should be attempted.

convertExpressions(Collection<ProcedureParameter>) - Static method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter

Utility method that converts a Collection of ProcedureParameter to a Map containing only expression parameters.

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.integration.support.converter.ObjectStringMessageConverter

ConvertingBytesMessageMapper - Class in org.springframework.integration.mapping

The BytesMessageMapper implementation to delegate to/from Message conversion into the provided MessageConverter.

ConvertingBytesMessageMapper(MessageConverter) - Constructor for class org.springframework.integration.mapping.ConvertingBytesMessageMapper

ConvertingMessagingTemplate() - Constructor for class org.springframework.integration.gateway.MessagingGatewaySupport.ConvertingMessagingTemplate

convertPayload(Message) - Method in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

convertRequestMappingToAnnotation(RequestMapping) - Static method in class org.springframework.integration.http.config.HttpContextUtils

Converts a provided RequestMapping to the Spring Web RequestMapping annotation.

convertStaticParameters(Collection<ProcedureParameter>) - Static method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter

Utility method that converts a Collection of ProcedureParameter to a Map containing only static parameters.

convertToDocument(Object) - Method in class org.springframework.integration.xml.DefaultXmlPayloadConverter

convertToDocument(Object) - Method in interface org.springframework.integration.xml.XmlPayloadConverter

convertToJdbcTypesEnum(String) - Static method in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum

Retrieve the matching enum constant for a provided String representation of the SQL Types.

convertToNode(Object) - Method in class org.springframework.integration.xml.DefaultXmlPayloadConverter

convertToNode(Object) - Method in interface org.springframework.integration.xml.XmlPayloadConverter

convertToSource(Object) - Method in class org.springframework.integration.xml.DefaultXmlPayloadConverter

convertToSource(Object) - Method in interface org.springframework.integration.xml.XmlPayloadConverter

convertToString(Object) - Method in class org.springframework.integration.http.support.DefaultHttpHeaderMapper

convertValue(Object, TypeDescriptor, TypeDescriptor) - Method in class org.springframework.integration.util.BeanFactoryTypeConverter

copy(InputStream) - Method in class org.springframework.integration.zip.transformer.SpringZipUtils

copy(InputStream, File) - Static method in class org.springframework.integration.zip.transformer.SpringZipUtils

copy(MessageGroup) - Method in class org.springframework.integration.store.AbstractMessageGroupStore

Used by expireMessageGroups.

copy(MessageGroup) - Method in class org.springframework.integration.store.SimpleMessageStore

copyFileToLocalDirectory(String, EvaluationContext, F, File, Session<F>) - Method in class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer

copyHeaders(Map<String, ?>) - Method in class org.springframework.integration.support.AbstractIntegrationMessageBuilder

Copy the name-value pairs from the provided Map.

copyHeaders(Map<String, ?>) - Method in class org.springframework.integration.support.BaseMessageBuilder

Copy the name-value pairs from the provided Map.

copyHeaders(Map<String, ?>) - Method in class org.springframework.integration.support.MutableMessageBuilder

copyHeadersIfAbsent(Map<String, ?>) - Method in class org.springframework.integration.support.AbstractIntegrationMessageBuilder

Copy the name-value pairs from the provided Map.

copyHeadersIfAbsent(Map<String, ?>) - Method in class org.springframework.integration.support.BaseMessageBuilder

Copy the name-value pairs from the provided Map.

copyHeadersIfAbsent(Map<String, ?>) - Method in class org.springframework.integration.support.MutableMessageBuilder

copyToSizedArray(byte[], int) - Method in class org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer

Copy size bytes to a new buffer exactly size bytes long.

CoroutinesUtils - Class in org.springframework.integration.util

Additional utilities for working with Kotlin Coroutines.

CorrelatingMessageBarrier - Class in org.springframework.integration.aggregator

This Endpoint serves as a barrier for messages that should not be processed yet.

CorrelatingMessageBarrier() - Constructor for class org.springframework.integration.aggregator.CorrelatingMessageBarrier

CorrelatingMessageBarrier(MessageGroupStore) - Constructor for class org.springframework.integration.aggregator.CorrelatingMessageBarrier

CORRELATION_DATA - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders

CORRELATION_ID - Static variable in class org.springframework.integration.IntegrationMessageHeaderAccessor

correlationExpression(String) - Method in class org.springframework.integration.dsl.CorrelationHandlerSpec

Configure the handler with an ExpressionEvaluatingCorrelationStrategy for the given expression.

CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler> - Class in org.springframework.integration.dsl

A MessageHandlerSpec for an AbstractCorrelatingMessageHandler.

CorrelationHandlerSpec(H) - Constructor for class org.springframework.integration.dsl.CorrelationHandlerSpec

correlationId(Object) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.

correlationId(Object, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.

correlationIdExpression(String) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is a SpEL Expression evaluation result.

correlationIdExpression(String, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is a SpEL Expression evaluation result.

correlationIdFunction(Function<Message<P>, ?>, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is obtained by invoking the Function callback.

correlationIdFunction(Function<Message<P>, Object>) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is obtained by invoking the Function callback.

correlationKey(String) - Method in class org.springframework.integration.jms.dsl.JmsInboundGatewaySpec

correlationKey(String) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec

correlationStrategy(Object, String) - Method in class org.springframework.integration.dsl.CorrelationHandlerSpec

Configure the handler with an MethodInvokingCorrelationStrategy for the target object and method name.

correlationStrategy(CorrelationStrategy) - Method in class org.springframework.integration.dsl.BarrierSpec

correlationStrategy(CorrelationStrategy) - Method in class org.springframework.integration.dsl.CorrelationHandlerSpec

CorrelationStrategy - Interface in org.springframework.integration.aggregator

Strategy for determining how messages can be correlated.

CorrelationStrategy - Annotation Interface in org.springframework.integration.annotation

Indicates that a given method is capable of determining the correlation key of a message sent as parameter.

CorrelationStrategyFactoryBean - Class in org.springframework.integration.config

Convenience factory for XML configuration of a CorrelationStrategy.

CorrelationStrategyFactoryBean() - Constructor for class org.springframework.integration.config.CorrelationStrategyFactoryBean

counterBuilder(String) - Method in interface org.springframework.integration.support.management.metrics.MetricsCaptor

Create a counter builder for a counter with the provided name.

counterBuilder(String) - Method in class org.springframework.integration.support.management.micrometer.MicrometerMetricsCaptor

CounterFacade - Interface in org.springframework.integration.support.management.metrics

create() - Method in class org.springframework.integration.ws.dsl.BaseWsOutboundGatewaySpec

create() - Method in class org.springframework.integration.ws.dsl.MarshallingWsOutboundGatewaySpec

create() - Method in class org.springframework.integration.ws.dsl.MarshallingWsOutboundGatewaySpec.MarshallingWsOutboundGatewayNoTemplateSpec

create() - Method in class org.springframework.integration.ws.dsl.SimpleWsOutboundGatewaySpec

create() - Method in class org.springframework.integration.ws.dsl.SimpleWsOutboundGatewaySpec.SimpleWsOutboundGatewayNoTemplateSpec

create(Object) - Method in interface org.springframework.integration.store.MessageGroupFactory

Create a MessageGroup instance based on the provided groupId.

create(Object) - Method in class org.springframework.integration.store.SimpleMessageGroupFactory

create(Object) - Method in class org.springframework.integration.transaction.DefaultTransactionSynchronizationFactory

create(Object) - Method in class org.springframework.integration.transaction.PassThroughTransactionSynchronizationFactory

create(Object) - Method in interface org.springframework.integration.transaction.TransactionSynchronizationFactory

create(Collection<? extends Message<?>>, Object) - Method in interface org.springframework.integration.store.MessageGroupFactory

Create a MessageGroup instance based on the provided groupId and with the messages for the group.

create(Collection<? extends Message<?>>, Object) - Method in class org.springframework.integration.store.SimpleMessageGroupFactory

create(Collection<? extends Message<?>>, Object, long, boolean) - Method in interface org.springframework.integration.store.MessageGroupFactory

Create a MessageGroup instance based on the provided groupId and with the messages for the group.

create(Collection<? extends Message<?>>, Object, long, boolean) - Method in class org.springframework.integration.store.SimpleMessageGroupFactory

create(MessageGroupStore, Object) - Method in interface org.springframework.integration.store.MessageGroupFactory

Create a MessageGroup instance based on the provided groupId.

create(MessageGroupStore, Object) - Method in class org.springframework.integration.store.SimpleMessageGroupFactory

create(MessageGroupStore, Object, long, boolean) - Method in interface org.springframework.integration.store.MessageGroupFactory

Create a MessageGroup instance based on the provided groupId.

create(MessageGroupStore, Object, long, boolean) - Method in class org.springframework.integration.store.SimpleMessageGroupFactory

create(Message<?>, String, Integer, Long, K, V, Headers) - Method in interface org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler.ProducerRecordCreator

Create a record.

CREATE - Enum constant in enum class org.springframework.integration.file.FileReadingMessageSource.WatchEventType

createCallback(AmqpMessageSource.AmqpAckInfo) - Method in class org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallbackFactory

createCallback(KafkaMessageSource.KafkaAckInfo<K, V>) - Method in record class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory

createCallback(T) - Method in interface org.springframework.integration.acks.AcknowledgmentCallbackFactory

Create the callback.

createClientInstance() - Method in class org.springframework.integration.ftp.session.AbstractFtpSessionFactory

createClientInstance() - Method in class org.springframework.integration.ftp.session.DefaultFtpSessionFactory

createClientInstance() - Method in class org.springframework.integration.ftp.session.DefaultFtpsSessionFactory

createConnection() - Method in class org.springframework.integration.jms.JmsOutboundGateway

Create a new JMS Connection for this JMS gateway.

createConsumer() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageSource

created(ServerSession, Path, Map<String, ?>, Throwable) - Method in class org.springframework.integration.sftp.server.ApacheMinaSftpEventListener

createDefaultHandler() - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

createDefaultHandler() - Method in class org.springframework.integration.config.SplitterFactoryBean

createDefaultHeaderMatcher(String, Collection<String>) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper

Create the initial AbstractHeaderMapper.HeaderMatcher based on the specified headers and standard header prefix.

createDirectChannel(Element, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

createDirectHandlerIfPossible(Object, String) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

If the target object is a MessageHandler and the method is 'handleMessage', return an AbstractMessageProducingHandler that wraps it.

createDispatcher() - Method in class org.springframework.integration.amqp.channel.PointToPointSubscribableAmqpChannel

createDispatcher() - Method in class org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel

createDispatcher() - Method in class org.springframework.integration.kafka.channel.PublishSubscribeKafkaChannel

createDispatcher() - Method in class org.springframework.integration.kafka.channel.SubscribableKafkaChannel

createElementDescription(Element) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

Provides a user friendly description of an element based on its node name and, if available, its "id" attribute value.

createEndpoint(MessageHandler, Method, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor

createEndpoint(MessageHandler, Method, List<Annotation>) - Method in class org.springframework.integration.config.BridgeToAnnotationPostProcessor

createEndpointBeanDefinition(ComponentDefinition, ComponentDefinition, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor

createEndpointBeanDefinition(ComponentDefinition, ComponentDefinition, List<Annotation>) - Method in class org.springframework.integration.config.BridgeToAnnotationPostProcessor

createEndpointBeanDefinition(ComponentDefinition, ComponentDefinition, List<Annotation>) - Method in class org.springframework.integration.config.InboundChannelAdapterAnnotationPostProcessor

createEvaluationContext() - Method in class org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice

createEvaluationContext() - Method in class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

createEvaluationContext() - Method in class org.springframework.integration.transaction.ExpressionEvaluatingTransactionSynchronizationProcessor

createExpressionDefIfAttributeDefined(String, Element) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

createExpressionDefinitionFromValueOrExpression(String, String, ParserContext, Element, boolean) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.FilterFactoryBean

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.RouterFactoryBean

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.SplitterFactoryBean

createExpressionEvaluatingHandler(Expression) - Method in class org.springframework.integration.config.TransformerFactoryBean

createFilter(MessageSelector) - Method in class org.springframework.integration.config.FilterFactoryBean

createForPool() - Method in interface org.springframework.integration.util.SimplePool.PoolItemCallback

Called by the pool when a new instance is required to populate the pool.

createHandler() - Method in class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean

createHandler() - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

createHandler() - Method in class org.springframework.integration.config.AggregatorFactoryBean

createHandler() - Method in class org.springframework.integration.config.ControlBusFactoryBean

createHandler() - Method in class org.springframework.integration.config.ExpressionControlBusFactoryBean

Deprecated.

createHandler() - Method in class org.springframework.integration.file.config.FileWritingMessageHandlerFactoryBean

createHandler() - Method in class org.springframework.integration.groovy.config.GroovyControlBusFactoryBean

Deprecated.

createHandler() - Method in class org.springframework.integration.jpa.outbound.JpaOutboundGatewayFactoryBean

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor

Subclasses must implement this method to create the MessageHandler.

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.AggregatorAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.BridgeFromAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.BridgeToAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.FilterAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.InboundChannelAdapterAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.RouterAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.ServiceActivatorAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.SplitterAnnotationPostProcessor

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.TransformerAnnotationPostProcessor

createHandler(Transformer) - Method in class org.springframework.integration.config.TransformerFactoryBean

createHandlerInternal() - Method in class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean

createHeaderMatcher(Collection<String>) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper

Create a AbstractHeaderMapper.HeaderMatcher that match if any of the specified patterns match.

createIndexes() - Method in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

createIndexes() - Method in class org.springframework.integration.mongodb.store.MongoDbChannelMessageStore

createInstance() - Method in class org.springframework.integration.amqp.config.AmqpChannelFactoryBean

createInstance() - Method in class org.springframework.integration.config.ExpressionFactoryBean

createInstance() - Method in class org.springframework.integration.file.config.FileReadingMessageSourceFactoryBean

createInstance() - Method in class org.springframework.integration.file.config.FileTailInboundChannelAdapterFactoryBean

createInstance() - Method in class org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean

createInstance() - Method in class org.springframework.integration.jms.config.JmsChannelFactoryBean

createInstance() - Method in class org.springframework.integration.mail.config.MailReceiverFactoryBean

createInstance() - Method in class org.springframework.integration.syslog.config.SyslogReceivingChannelAdapterFactoryBean

createInstance() - Method in class org.springframework.integration.xmpp.config.XmppConnectionFactoryBean

createInvocableHandlerMethod(Object, Method) - Method in class org.springframework.integration.handler.support.IntegrationMessageHandlerMethodFactory

createJavaType(Map<String, Object>, String) - Method in class org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper

createJsonParser(String) - Method in class org.springframework.integration.support.json.Jackson2JsonMessageParser

createMessageFromAmqp(Message, Channel) - Method in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

createMessageFromPayload(Object, Channel, Map<String, Object>, long, List<Map<String, Object>>) - Method in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

createMessageProcessingHandler(MessageProcessor<T>) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

createMessageProcessingHandler(MessageProcessor<T>) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

createMessageProcessor(String, ScriptSource, ScriptVariableGenerator) - Method in class org.springframework.integration.groovy.config.GroovyAwareScriptExecutingProcessorFactory

createMessageProcessor(String, ScriptSource, ScriptVariableGenerator) - Method in class org.springframework.integration.scripting.config.ScriptExecutingProcessorFactory

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean

Subclasses must implement this method to create the MessageHandler.

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.FilterFactoryBean

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.RouterFactoryBean

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.SplitterFactoryBean

createMethodInvokingHandler(Object, String) - Method in class org.springframework.integration.config.TransformerFactoryBean

createMethodInvokingRouter(Object, String) - Method in class org.springframework.integration.config.RouterFactoryBean

createMethodInvokingSplitter(Object, String) - Method in class org.springframework.integration.config.SplitterFactoryBean

createNewConnection(Socket, boolean, boolean, ApplicationEventPublisher, String) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpNetConnectionSupport

createNewConnection(Socket, boolean, boolean, ApplicationEventPublisher, String) - Method in interface org.springframework.integration.ip.tcp.connection.TcpNetConnectionSupport

Create a new TcpNetConnection object wrapping the Socket.

createNewConnection(SocketChannel, boolean, boolean, ApplicationEventPublisher, String) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpNioConnectionSupport

createNewConnection(SocketChannel, boolean, boolean, ApplicationEventPublisher, String) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpNioSSLConnectionSupport

Creates a TcpNioSSLConnection.

createNewConnection(SocketChannel, boolean, boolean, ApplicationEventPublisher, String) - Method in interface org.springframework.integration.ip.tcp.connection.TcpNioConnectionSupport

Create a new TcpNioConnection object wrapping the SocketChannel.

createOutputMessage(Object, MessageHeaders) - Method in class org.springframework.integration.handler.AbstractMessageProducingHandler

createOutputStream(File, boolean) - Method in class org.springframework.integration.file.FileWritingMessageHandler

Create a buffered output stream for the file.

createParameterSource(Object) - Method in class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory

createParameterSource(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory

createParameterSource(Object) - Method in interface org.springframework.integration.jdbc.SqlParameterSourceFactory

Return a new SqlParameterSource.

createParameterSource(Object) - Method in class org.springframework.integration.jpa.support.parametersource.BeanPropertyParameterSourceFactory

createParameterSource(Object) - Method in class org.springframework.integration.jpa.support.parametersource.ExpressionEvaluatingParameterSourceFactory

createParameterSource(Object) - Method in interface org.springframework.integration.jpa.support.parametersource.ParameterSourceFactory

Return a new ParameterSource.

createParameterSourceNoCache(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory

Create an expression evaluating SqlParameterSource that does not cache it's results.

createResult(Object) - Method in class org.springframework.integration.xml.result.DomResultFactory

createResult(Object) - Method in interface org.springframework.integration.xml.result.ResultFactory

createResult(Object) - Method in class org.springframework.integration.xml.result.StringResultFactory

createSelect(String) - Method in class org.springframework.integration.r2dbc.inbound.R2dbcMessageSource.SelectCreator

createSelect(SqlIdentifier) - Method in class org.springframework.integration.r2dbc.inbound.R2dbcMessageSource.SelectCreator

createServerSocket(int, int, InetAddress) - Method in class org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory

Create a new ServerSocket.

createSession() - Method in class org.springframework.integration.smb.session.SmbSessionFactory

createSession(Connection) - Method in class org.springframework.integration.jms.JmsOutboundGateway

Create a new JMS Session using the provided Connection.

createSftpChannelSubsystem(ClientSession) - Method in class org.springframework.integration.sftp.session.DefaultSftpSessionFactory.ConcurrentSftpClient

createSftpClient(ClientSession, SftpVersionSelector, SftpErrorDataHandler) - Method in class org.springframework.integration.sftp.session.DefaultSftpSessionFactory

Can be overridden to provide a custom SftpClient to DefaultSftpSessionFactory.getSession().

createSimpleEvaluationContext() - Static method in class org.springframework.integration.expression.ExpressionUtils

Used to create a context with no BeanFactory, usually in tests.

createSimpleEvaluationContext(BeanFactory) - Static method in class org.springframework.integration.expression.ExpressionUtils

Obtains the context from the beanFactory if not null; emits a warning if the beanFactory is null.

createSmbDirectoryObject(String) - Method in class org.springframework.integration.smb.session.SmbSession

Create an SMB file object pointing to a remote directory.

createSmbFileObject(String) - Method in class org.springframework.integration.smb.session.SmbSession

Create an SMB file object pointing to a remote file.

createSocket(String, int) - Method in class org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory

Create a new Socket.

createSource(Object) - Method in class org.springframework.integration.xml.source.DomSourceFactory

createSource(Object) - Method in interface org.springframework.integration.xml.source.SourceFactory

Create appropriate Source instance for payload

createSource(Object) - Method in class org.springframework.integration.xml.source.StringSourceFactory

createStandardEvaluationContext() - Static method in class org.springframework.integration.expression.ExpressionUtils

Used to create a context with no BeanFactory, usually in tests.

createStandardEvaluationContext(BeanFactory) - Static method in class org.springframework.integration.expression.ExpressionUtils

Obtains the context from the beanFactory if not null; emits a warning if the beanFactory is null.

createTargetPropertyName(String, boolean) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper

Alter the specified propertyName if necessary.

createTaskScheduler(int) - Static method in class org.springframework.integration.test.util.TestUtils

A factory for the ThreadPoolTaskScheduler instances based on the provided poolSize.

createTestApplicationContext() - Static method in class org.springframework.integration.test.util.TestUtils

Create a TestUtils.TestApplicationContext instance supplied with the basic Spring Integration infrastructure.

createWriter(File, boolean) - Method in class org.springframework.integration.file.FileWritingMessageHandler

Create a buffered writer for the file, for String payloads.

credentials(String, String) - Method in class org.springframework.integration.mail.dsl.MailSendingMessageHandlerSpec

Set the credentials.

criteria(String) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a SpEL expression to evaluate a Criteria for query to execute.

criteria(Function<Message<P>, Criteria>) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a Function to evaluate a Criteria for query to execute.

criteria(Expression) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a SpEL expression to evaluate a Criteria for query to execute.

CRITICAL - Enum constant in enum class org.springframework.integration.syslog.RFC5424SyslogParser.Severity

crlf() - Static method in class org.springframework.integration.ip.tcp.serializer.TcpCodecs

Return a serializer with the default max message size for deserialization.

crlf(int) - Static method in class org.springframework.integration.ip.tcp.serializer.TcpCodecs

Return a serializer with the provided max message size for deserialization.

cron() - Element in annotation interface org.springframework.integration.annotation.Poller

cron(String) - Method in class org.springframework.integration.dsl.PollerFactory

Create a PollerSpec based on the provided cron expression.

cron(String) - Static method in class org.springframework.integration.dsl.Pollers

Create a PollerSpec based on the provided cron expression.

cron(String, TimeZone) - Method in class org.springframework.integration.dsl.PollerFactory

Create a PollerSpec based on the provided cron expression and TimeZone.

cron(String, TimeZone) - Static method in class org.springframework.integration.dsl.Pollers

Create a PollerSpec based on the provided cron expression and TimeZone.

crossOrigin(Consumer<HttpInboundEndpointSupportSpec.CrossOriginSpec>) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec

Provide a Consumer for configuring CrossOrigin via HttpInboundEndpointSupportSpec.CrossOriginSpec.

CrossOrigin - Class in org.springframework.integration.http.inbound

The mapping to permit cross origin requests (CORS) for HttpRequestHandlingEndpointSupport.

CrossOrigin() - Constructor for class org.springframework.integration.http.inbound.CrossOrigin

CuratorFrameworkFactoryBean - Class in org.springframework.integration.zookeeper.config

A Spring-friendly way to build a CuratorFramework and implementing SmartLifecycle.

CuratorFrameworkFactoryBean(String) - Constructor for class org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean

Construct an instance using the supplied connection string and using a default retry policy new ExponentialBackoffRetry(1000, 3).

CuratorFrameworkFactoryBean(String, RetryPolicy) - Constructor for class org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean

Construct an instance using the supplied connection string and retry policy.

currencyTimeLimit() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource

current() - Method in class org.springframework.integration.syslog.RFC5424SyslogParser.Reader

currentComponent(Object) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

currentInterceptableChannel() - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Return the current channel if it is an InterceptableChannel, otherwise register a new implicit DirectChannel in the flow and return that one.

currentMessageChannel(MessageChannel) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

customizeMonoReply(BiFunction<Message<?>, Mono<T>, Publisher<V>>) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec

Specify a BiFunction for customizing Mono replies via ReactiveRequestHandlerAdvice.

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form