C-Index (Spring Integration 6.0.5 API)

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

C

CACHE_NAME - Static variable in class org.springframework.integration.hazelcast.HazelcastHeaders: The cache name header name.
CacheEventType - Enum Class in org.springframework.integration.hazelcast: Enumeration of Cache Event Types.
cacheLevel(int) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec: Specify the level of caching that this listener container is allowed to apply.
cacheLevel(Integer) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec: Only applies if the JmsMessageChannelSpec.containerType(Class) is a DefaultMessageListenerContainer.
cacheLevel(Integer) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec.ReplyContainerSpec
cacheLevelName(String) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec: Specify the level of caching that this listener container is allowed to apply, in the form of the name of the corresponding constant: e.g.
CacheListeningPolicyType - Enum Class in org.springframework.integration.hazelcast: Enumeration of Cache Listening Policy Type.
CacheRequestHandlerAdvice - Class in org.springframework.integration.handler.advice: The AbstractRequestHandlerAdvice implementation for caching AbstractReplyProducingMessageHandler.RequestHandler#handleRequestMessage(Message) results.
CacheRequestHandlerAdvice(String...) - Constructor for class org.springframework.integration.handler.advice.CacheRequestHandlerAdvice: Create a CacheRequestHandlerAdvice instance based on the provided name of caches and CacheableOperation as default one.
CachingClientConnectionFactory - Class in org.springframework.integration.ip.tcp.connection: Connection factory that caches connections from the underlying target factory.
CachingClientConnectionFactory(AbstractClientConnectionFactory, int) - Constructor for class org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory: Construct a caching connection factory that delegates to the provided factory, with the provided pool size.
CachingSessionFactory<F> - Class in org.springframework.integration.file.remote.session: A SessionFactory implementation that caches Sessions for reuse without requiring reconnection each time the Session is retrieved from the factory.
CachingSessionFactory(SessionFactory<F>) - Constructor for class org.springframework.integration.file.remote.session.CachingSessionFactory: Create a CachingSessionFactory with an unlimited number of sessions.
CachingSessionFactory(SessionFactory<F>, int) - Constructor for class org.springframework.integration.file.remote.session.CachingSessionFactory: Create a CachingSessionFactory with the specified session limit.
CachingSessionFactory.CachedSession - Class in org.springframework.integration.file.remote.session
call() - Method in class org.springframework.integration.hazelcast.leader.LeaderInitiator.LeaderSelector
call() - Method in class org.springframework.integration.support.leader.LockRegistryLeaderInitiator.LeaderSelector
CallerBlocksPolicy - Class in org.springframework.integration.util: A RejectedExecutionHandler that blocks the caller until the executor has room in its queue, or a timeout occurs (in which case a RejectedExecutionException is thrown.
CallerBlocksPolicy(long) - Constructor for class org.springframework.integration.util.CallerBlocksPolicy: Construct instance based on the provided maximum wait time.
Camel - Class in org.springframework.integration.camel.dsl: Factory class for Apache Camel components DSL.
CamelHeaderMapper - Class in org.springframework.integration.camel.support: A HeaderMapper for mapping headers from Spring Integration message to Apache Camel message and back.
CamelHeaderMapper() - Constructor for class org.springframework.integration.camel.support.CamelHeaderMapper
CamelMessageHandler - Class in org.springframework.integration.camel.outbound: A MessageHandler for calling Apache Camel route and produce (optionally) a reply.
CamelMessageHandler() - Constructor for class org.springframework.integration.camel.outbound.CamelMessageHandler
CamelMessageHandler(ProducerTemplate) - Constructor for class org.springframework.integration.camel.outbound.CamelMessageHandler
CamelMessageHandlerSpec - Class in org.springframework.integration.camel.dsl: The MessageHandlerSpec for CamelMessageHandler.
CamelMessageHandlerSpec(ProducerTemplate) - Constructor for class org.springframework.integration.camel.dsl.CamelMessageHandlerSpec
canAdd(Message<?>) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup: This method determines whether messages have been added to this group that supersede the given message based on its sequence id.
canAdd(Message<?>) - Method in interface org.springframework.integration.store.MessageGroup: Query if the message can be added.
canAdd(Message<?>) - Method in class org.springframework.integration.store.SimpleMessageGroup
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.FilterFactoryBean: MessageFilter is an ARPMH.
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.RouterFactoryBean
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean: Always returns true - any AbstractMessageProducingHandler can be used directly.
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.SplitterFactoryBean
canBeUsedDirect(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.TransformerFactoryBean: Always returns true - any AbstractMessageProducingHandler can be used directly.
cancelIdleInterval(long) - Method in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec: How often to recycle the idle task (in case of a silently dropped connection).
cancelPing() - Method in class org.springframework.integration.mail.ImapMailReceiver: The hook to be called when we need to cancel the current ping task and close the mail folder.
canConvert(Class<?>, Class<?>) - Method in class org.springframework.integration.util.BeanFactoryTypeConverter
canConvert(TypeDescriptor, TypeDescriptor) - Method in class org.springframework.integration.util.BeanFactoryTypeConverter
Candidate - Interface in org.springframework.integration.leader: Interface that defines the contract for candidates to participate in a leader election.
canRead(Class<?>, MediaType) - Method in class org.springframework.integration.http.converter.MultipartAwareFormHttpMessageConverter
canRead(EvaluationContext, Object, 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: The MessageHandlerSpec for CassandraMessageHandler.
CassandraMessageHandlerSpec(ReactiveCassandraOperations) - Constructor for class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
CassandraMessageHandlerSpec(ReactiveCassandraOperations, CassandraMessageHandler.Type) - Constructor for class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
CassandraNamespaceHandler - Class in org.springframework.integration.cassandra.config.xml: The namespace handler for "int-cassandra" namespace.
CassandraNamespaceHandler() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraNamespaceHandler
CassandraOutboundChannelAdapterParser - Class in org.springframework.integration.cassandra.config.xml: The parser for the <int-cassandra:outbound-channel-adapter>.
CassandraOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraOutboundChannelAdapterParser
CassandraOutboundGatewayParser - Class in org.springframework.integration.cassandra.config.xml: The parser for the <int-cassandra:outbound-gateway>.
CassandraOutboundGatewayParser() - Constructor for class org.springframework.integration.cassandra.config.xml.CassandraOutboundGatewayParser
CassandraParserUtils - Class in org.springframework.integration.cassandra.config.xml: The int-cassandra namespace XML parser helper.
categories() - Element in annotation interface org.springframework.integration.test.condition.LogLevels: Category names representing Log4j categories to change.
categories(boolean, String...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster: Specify the categories for logging level adjusting configured before.
categories(String...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster: Specify the categories for logging level adjusting configured before.
categoryLevels() - Method in record class org.springframework.integration.test.util.TestUtils.LevelsContainer: Returns the value of the categoryLevels record component.
cause - Variable in class org.springframework.integration.events.IntegrationEvent
cc(String...) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder: Set the cc: addresses.
CC - Static variable in class org.springframework.integration.mail.MailHeaders
ccExpression(String) - Method in class org.springframework.integration.mail.dsl.MailHeadersBuilder: Set the expression that will be evaluated to determine the cc: addresses.
ccFunction(Function<Message, 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: Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore.
claimCheckIn(MessageStore, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Populate the MessageTransformingHandler for the ClaimCheckInTransformer with provided MessageStore.
ClaimCheckInParser - Class in org.springframework.integration.config.xml: Parser for the <claim-check-in/> element.
ClaimCheckInParser() - Constructor for class org.springframework.integration.config.xml.ClaimCheckInParser
ClaimCheckInTransformer - Class in org.springframework.integration.transformer: Transformer that stores a Message and returns a new Message whose payload is the id of the stored Message.
ClaimCheckInTransformer(MessageStore) - Constructor for class org.springframework.integration.transformer.ClaimCheckInTransformer: Create a claim check-in transformer that will delegate to the provided MessageStore.
claimCheckOut(MessageStore) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore.
claimCheckOut(MessageStore, boolean) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.
claimCheckOut(MessageStore, boolean, Consumer<GenericEndpointSpec<MessageTransformingHandler>>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Populate the MessageTransformingHandler for the ClaimCheckOutTransformer with provided MessageStore and removeMessage flag.
ClaimCheckOutParser - Class in org.springframework.integration.config.xml: Parser for the <claim-check-out/> element.
ClaimCheckOutParser() - Constructor for class org.springframework.integration.config.xml.ClaimCheckOutParser
ClaimCheckOutTransformer - Class in org.springframework.integration.transformer: Transformer that accepts a Message whose payload is a UUID and retrieves the Message associated with that id from a MessageStore if available.
ClaimCheckOutTransformer(MessageStore) - Constructor for class org.springframework.integration.transformer.ClaimCheckOutTransformer: Create a claim check-out transformer that will delegate to the provided MessageStore.
classes() - Element in annotation interface org.springframework.integration.test.condition.LogLevels: Classes representing Log4j categories to change.
classes(boolean, Class<?>...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster: Specify the classes for logging level adjusting configured before.
classes(Class<?>...) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster: Specify the classes for logging level adjusting configured before.
classLevels() - Method in record class org.springframework.integration.test.util.TestUtils.LevelsContainer: Returns the value of the classLevels record component.
ClassUtils - Class in org.springframework.integration.util
ClassUtils() - Constructor for class org.springframework.integration.util.ClassUtils
clear() - Method in class org.springframework.integration.channel.QueueChannel
clear() - Method in interface org.springframework.integration.channel.QueueChannelOperations: Remove all Messages from this channel.
clear() - Method in class org.springframework.integration.expression.ExpressionEvalMap
clear() - Method in class org.springframework.integration.history.MessageHistory
clear() - Method in interface org.springframework.integration.store.MessageGroup
clear() - Method in class org.springframework.integration.store.SimpleMessageGroup
clear() - Method in class org.springframework.integration.support.MutableMessageHeaders
CLEAR_ALL - Enum constant in enum class org.springframework.integration.hazelcast.CacheEventType: The Hazelcast CLEAR_ALL event.
clearCache() - Method in class org.springframework.integration.expression.ReloadableResourceBundleExpressionSource: Clear the resource bundle cache.
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: A HandlerMethodArgumentResolver implementation for Collection, Iterator or array MethodParameter.
CollectionArgumentResolver(boolean) - Constructor for class org.springframework.integration.handler.support.CollectionArgumentResolver
collectionCallback(MessageCollectionCallback) - 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, 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, 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: Fluent version of MetadataStoreSelector.setCompareValues(BiPredicate).
compilerMode() - Element in annotation interface org.springframework.integration.annotation.UseSpelInvoker: Specify that the annotated method (or methods in the annotated class) will be invoked using SpEL instead of an InvocableHandlerMethod with the specified compilerMode.
complete() - Method in interface org.springframework.integration.store.MessageGroup: Complete the group.
complete() - Method in class org.springframework.integration.store.MessageGroupMetadata
complete() - Method in class org.springframework.integration.store.SimpleMessageGroup
COMPLETE - Static variable in class org.springframework.integration.mongodb.store.MessageDocumentFields
completeGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore
completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore
completeGroup(Object) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore
completeGroup(Object) - Method in class org.springframework.integration.store.AbstractKeyValueMessageStore
completeGroup(Object) - Method in interface org.springframework.integration.store.MessageGroupStore: Completes this MessageGroup.
completeGroup(Object) - Method in class org.springframework.integration.store.SimpleMessageStore
completeGroup(Object, MessageGroup, Lock) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler
completeGroup(Message<?>, Object, MessageGroup, Lock) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler
COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.GatewayTags: Name of the message gateway component.
COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.HandlerTags: Name of the message handler component.
COMPONENT_NAME - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.ProducerTags: Name of the message handler component.
COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.GatewayTags: Type of the component - 'gateway'.
COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.HandlerTags: Type of the component - 'handler'.
COMPONENT_TYPE - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation.ProducerTags: Type of the component - 'producer'.
ComponentsEvaluationCallback(EvaluationContext, Object, boolean, Class<?>) - Constructor for class org.springframework.integration.expression.ExpressionEvalMap.ComponentsEvaluationCallback
ComponentsRegistration - Interface in org.springframework.integration.dsl: The marker interface for the IntegrationComponentSpec implementation, when there is need to register as beans not only the target spec's components, but some additional components, e.g.
componentsToRegister - Variable in class org.springframework.integration.dsl.EndpointSpec
componentsToRegister - Variable in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec
CompositeCodec - Class in org.springframework.integration.codec: A Codec that can delegate to one out of many Codecs, each mapped to a class.
CompositeCodec(Map<Class<?>, Codec>, Codec) - Constructor for class org.springframework.integration.codec.CompositeCodec
CompositeCodec(Codec) - Constructor for class org.springframework.integration.codec.CompositeCodec
CompositeExecutor - Class in org.springframework.integration.util: An Executor that encapsulates two underlying executors.
CompositeExecutor(Executor, Executor) - Constructor for class org.springframework.integration.util.CompositeExecutor
CompositeFileListFilter<F> - Class in org.springframework.integration.file.filters: Simple FileListFilter that predicates its matches against all of the configured FileListFilter.
CompositeFileListFilter() - Constructor for class org.springframework.integration.file.filters.CompositeFileListFilter
CompositeFileListFilter(Collection<? extends FileListFilter<F>>) - Constructor for class org.springframework.integration.file.filters.CompositeFileListFilter
CompositeKryoRegistrar - Class in org.springframework.integration.codec.kryo: A KryoRegistrar that delegates and validates registrations across all components.
CompositeKryoRegistrar(List<KryoRegistrar>) - Constructor for class org.springframework.integration.codec.kryo.CompositeKryoRegistrar
CompositeMessageHandler - Interface in org.springframework.integration.handler: Classes implementing this interface delegate to a list of handlers.
CompositeMessageHandlerNode - Class in org.springframework.integration.graph: Represents a composite message handler.
CompositeMessageHandlerNode(int, String, MessageHandler, String, String, List<CompositeMessageHandlerNode.InnerHandler>) - Constructor for class org.springframework.integration.graph.CompositeMessageHandlerNode
CompositeMessageHandlerNode.InnerHandler - Class in org.springframework.integration.graph
CompoundTrigger - Class in org.springframework.integration.util: A Trigger that delegates the Trigger.nextExecutionTime(TriggerContext) to one of two Triggers.
CompoundTrigger(Trigger) - Constructor for class org.springframework.integration.util.CompoundTrigger: Construct a compound trigger with the supplied primary trigger.
CompoundTriggerAdvice - Class in org.springframework.integration.aop: A MessageSourceMutator that uses a CompoundTrigger to adjust the poller - when a message is present, the compound trigger's primary trigger is used to determine the next poll.
CompoundTriggerAdvice(CompoundTrigger, Trigger) - Constructor for class org.springframework.integration.aop.CompoundTriggerAdvice
concurrency(int) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec: Specify a concurrency maximum number for the AbstractMessageListenerContainer.
concurrency(String) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec: The concurrency to use.
concurrentConsumers(int) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec
concurrentConsumers(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
concurrentConsumers(int) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec: The concurrent consumers number to use.
concurrentConsumers(int) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec: Only applies if the JmsMessageChannelSpec.containerType(Class) is a DefaultMessageListenerContainer or a SimpleMessageListenerContainer.
concurrentConsumers(Integer) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec.ReplyContainerSpec
ConcurrentMetadataStore - Interface in org.springframework.integration.metadata: Supports atomic updates to values in the store.
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: The TcpNioConnectionSupport to use.
connectionSupport(TcpNioConnectionSupport) - Method in class org.springframework.integration.ip.dsl.TcpNioServerConnectionFactorySpec: The TcpNioConnectionSupport to use.
connectTimeout(int) - Method in class org.springframework.integration.ip.dsl.TcpClientConnectionFactorySpec: Set the connection timeout in seconds.
connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec: Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.
connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec: Configure an URL for ZMQ.Socket.connect(String).
consecutiveActiveTrigger(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
consecutiveIdleTrigger(int) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec
ConsoleInboundChannelAdapterParser - Class in org.springframework.integration.stream.config: Parser for the <stdin-channel-adapter> element.
ConsoleInboundChannelAdapterParser() - Constructor for class org.springframework.integration.stream.config.ConsoleInboundChannelAdapterParser
ConsoleOutboundChannelAdapterParser - Class in org.springframework.integration.stream.config: Parser for the "stdout-" and "stderr-channel-adapter" elements.
ConsoleOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.stream.config.ConsoleOutboundChannelAdapterParser
CONSOLIDATED_HEADERS - Static variable in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter: Header containing List<Map<String, Object> headers when batch mode is AmqpInboundChannelAdapter.BatchMode.EXTRACT_PAYLOADS_WITH_HEADERS.
constructType(Type) - Method in class org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper
constructType(Type) - Method in class org.springframework.integration.support.json.Jackson2JsonObjectMapper
consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec: Specify a Duration to delay consumption when no data received.
consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec: Specify a Duration to delay consumption when no data received.
CONSUMER - Static variable in class org.springframework.integration.redis.support.RedisHeaders
CONSUMER_GROUP - Static variable in class org.springframework.integration.redis.support.RedisHeaders
consumerArguments(Map<String, Object>) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec: Set consumer arguments.
consumerBatchEnabled(boolean) - Method in class org.springframework.integration.amqp.dsl.SimpleMessageListenerContainerSpec: Set to true to enable batching of consumed messages.
consumerCustomizer(ConsumerCustomizer) - Method in class org.springframework.integration.amqp.dsl.RabbitStreamMessageListenerContainerSpec: Set a consumer customizer.
ConsumerEndpointFactoryBean - Class in org.springframework.integration.config: The FactoryBean implementation for AbstractEndpoint population.
ConsumerEndpointFactoryBean() - Constructor for class org.springframework.integration.config.ConsumerEndpointFactoryBean
ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends MessageHandler> - Class in org.springframework.integration.dsl: A EndpointSpec for consumer endpoints.
ConsumerEndpointSpec(H) - Constructor for class org.springframework.integration.dsl.ConsumerEndpointSpec
consumerProperties() - Method in record class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory: Returns the value of the consumerProperties record component.
consumerRebalanceListener(ConsumerRebalanceListener) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec: Set the user defined ConsumerRebalanceListener implementation.
consumersPerQueue(int) - Method in class org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec
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, 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) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Populate the MessageTransformingHandler instance for the provided payloadType to convert at runtime.
convert(Class, 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: A MessageHandlerSpec for an AbstractCorrelatingMessageHandler.
CorrelationHandlerSpec(H) - Constructor for class org.springframework.integration.dsl.CorrelationHandlerSpec
correlationId(Object) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec: Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.
correlationId(Object, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec: Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.
correlationIdExpression(String) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec: Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is a SpEL Expression evaluation result.
correlationIdExpression(String, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec: Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header where the value is a SpEL Expression evaluation result.
correlationIdFunction(Function<Message, ?>, 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, 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.
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: Creates a TcpNioSSLConnection.
createNewConnection(SocketChannel, boolean, boolean, ApplicationEventPublisher, String) - Method in interface org.springframework.integration.ip.tcp.connection.TcpNioConnectionSupport: Create a new TcpNioConnection object wrapping the SocketChannel.
createOutputMessage(Object, MessageHeaders) - Method in class org.springframework.integration.handler.AbstractMessageProducingHandler
createOutputStream(File, boolean) - Method in class org.springframework.integration.file.FileWritingMessageHandler: Create a buffered output stream for the file.
createParameterSource(Object) - Method in class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory
createParameterSource(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
createParameterSource(Object) - Method in interface org.springframework.integration.jdbc.SqlParameterSourceFactory: Return a new SqlParameterSource.
createParameterSource(Object) - Method in class org.springframework.integration.jpa.support.parametersource.BeanPropertyParameterSourceFactory
createParameterSource(Object) - Method in class org.springframework.integration.jpa.support.parametersource.ExpressionEvaluatingParameterSourceFactory
createParameterSource(Object) - Method in interface org.springframework.integration.jpa.support.parametersource.ParameterSourceFactory: Return a new ParameterSource.
createParameterSourceNoCache(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory: Create an expression evaluating SqlParameterSource that does not cache it's results.
createResult(Object) - Method in class org.springframework.integration.xml.result.DomResultFactory
createResult(Object) - Method in interface org.springframework.integration.xml.result.ResultFactory
createResult(Object) - Method in class org.springframework.integration.xml.result.StringResultFactory
createSelect(String) - Method in class org.springframework.integration.r2dbc.inbound.R2dbcMessageSource.SelectCreator
createSelect(SqlIdentifier) - Method in class org.springframework.integration.r2dbc.inbound.R2dbcMessageSource.SelectCreator
createServerSocket(int, int, InetAddress) - Method in class org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory: Create a new ServerSocket.
createSession() - Method in class org.springframework.integration.smb.session.SmbSessionFactory
createSession(Connection) - Method in class org.springframework.integration.jms.JmsOutboundGateway: Create a new JMS Session using the provided Connection.
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, 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: Provide a Consumer for configuring CrossOrigin via HttpInboundEndpointSupportSpec.CrossOriginSpec.
CrossOrigin - Class in org.springframework.integration.http.inbound: The mapping to permit cross origin requests (CORS) for HttpRequestHandlingEndpointSupport.
CrossOrigin() - Constructor for class org.springframework.integration.http.inbound.CrossOrigin
CuratorFrameworkFactoryBean - Class in org.springframework.integration.zookeeper.config: A Spring-friendly way to build a CuratorFramework and implementing SmartLifecycle.
CuratorFrameworkFactoryBean(String) - Constructor for class org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean: Construct an instance using the supplied connection string and using a default retry policy new ExponentialBackoffRetry(1000, 3).
CuratorFrameworkFactoryBean(String, RetryPolicy) - Constructor for class org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean: Construct an instance using the supplied connection string and retry policy.
currencyTimeLimit() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource
current() - Method in class org.springframework.integration.syslog.RFC5424SyslogParser.Reader
currentComponent(Object) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
currentInterceptableChannel() - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition: Return the current channel if it is an InterceptableChannel, otherwise register a new implicit DirectChannel in the flow and return that one.
currentMessageChannel(MessageChannel) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
customizeMonoReply(BiFunction<Message<?>, Mono<T>, Publisher<V>>) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec: Specify a BiFunction for customizing Mono replies via ReactiveRequestHandlerAdvice.

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