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
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
 
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
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, 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, 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
 
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
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
 
ChannelAccessPolicy - Interface in org.springframework.integration.security.channel
Deprecated.
since 6.0 in favor of literally new AuthorizationChannelInterceptor(AuthorityAuthorizationManager.hasAnyRole())
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
 
ChannelInvocation - Class in org.springframework.integration.security.channel
Deprecated.
since 6.0 in favor of literally new AuthorizationChannelInterceptor(AuthorityAuthorizationManager.hasAnyRole())
ChannelInvocation(MethodInvocation) - Constructor for class org.springframework.integration.security.channel.ChannelInvocation
Deprecated.
 
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, LobHandler) - 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.
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.
ChannelSecurityInterceptor - Class in org.springframework.integration.security.channel
Deprecated.
since 6.0 in favor of literally new AuthorizationChannelInterceptor(AuthorityAuthorizationManager.hasAnyRole()). However, the AuthorizationChannelInterceptor can be configured with any AuthorizationManager implementation.
ChannelSecurityInterceptor() - Constructor for class org.springframework.integration.security.channel.ChannelSecurityInterceptor
Deprecated.
 
ChannelSecurityInterceptor(ChannelSecurityMetadataSource) - Constructor for class org.springframework.integration.security.channel.ChannelSecurityInterceptor
Deprecated.
 
ChannelSecurityInterceptorBeanPostProcessor - Class in org.springframework.integration.security.config
Deprecated.
since 6.0 in favor of literally new AuthorizationChannelInterceptor(AuthorityAuthorizationManager.hasAnyRole())
ChannelSecurityInterceptorBeanPostProcessor(Map<String, Set<Pattern>>) - Constructor for class org.springframework.integration.security.config.ChannelSecurityInterceptorBeanPostProcessor
Deprecated.
 
ChannelSecurityInterceptorBeanPostProcessor(Map<String, Set<Pattern>>, Map<String, Map<Pattern, ChannelAccessPolicy>>) - Constructor for class org.springframework.integration.security.config.ChannelSecurityInterceptorBeanPostProcessor
Deprecated.
 
ChannelSecurityMetadataSource - Class in org.springframework.integration.security.channel
Deprecated.
since 6.0 in favor of literally new AuthorizationChannelInterceptor(AuthorityAuthorizationManager.hasAnyRole())
ChannelSecurityMetadataSource() - Constructor for class org.springframework.integration.security.channel.ChannelSecurityMetadataSource
Deprecated.
 
ChannelSecurityMetadataSource(Map<Pattern, ChannelAccessPolicy>) - Constructor for class org.springframework.integration.security.channel.ChannelSecurityMetadataSource
Deprecated.
 
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(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.
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
claimCheckIn(MessageStore, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
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
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.
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
 
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
 
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.
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
 
close(RetryContext, RetryCallback<T, E>, Throwable) - Method in class org.springframework.integration.handler.advice.RequestHandlerRetryAdvice
 
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.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
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 - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 
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
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
 
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
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.
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
 
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
connectionSupport(TcpNioConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNioServerConnectionFactorySpec
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
 
ConsumerStopAction - Enum Class in org.springframework.integration.mqtt.core
Deprecated.
since 5.5.17 in favor of standard MqttConnectOptions.setCleanSession(boolean). Will be removed in 6.1.0.
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.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.
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
 
controlBus() - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
Populate the Control Bus EI Pattern specific MessageHandler implementation at the current IntegrationFlow chain position.
controlBus(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.
ControlBusMethodFilter - Class in org.springframework.integration.expression
SpEL MethodFilter to restrict method invocations to: Pausable or Lifecycle components get, set and shutdown methods of CustomizableThreadCreator methods with ManagedAttribute and ManagedOperation annotations This class isn't designed for target applications and typically is used from ExpressionControlBusFactoryBean.
ControlBusMethodFilter() - Constructor for class org.springframework.integration.expression.ControlBusMethodFilter
 
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(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.MessageBuilder
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.MessageBuilder
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
CorrelationHandlerSpec(H) - Constructor for class org.springframework.integration.dsl.CorrelationHandlerSpec
 
correlationId(Object) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
correlationId(Object, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
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.ExpressionControlBusFactoryBean
 
createHandler() - Method in class org.springframework.integration.file.config.FileWritingMessageHandlerFactoryBean
 
createHandler() - Method in class org.springframework.integration.groovy.config.GroovyControlBusFactoryBean
 
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.dsl.IntegrationComponentSpec
 
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
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.
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
 
cron(String) - Static method in class org.springframework.integration.dsl.Pollers
 
cron(String, TimeZone) - Method in class org.springframework.integration.dsl.PollerFactory
 
cron(String, TimeZone) - Static method in class org.springframework.integration.dsl.Pollers
 
crossOrigin(Consumer<HttpInboundEndpointSupportSpec.CrossOriginSpec>) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec
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