Index

A

AbstractAggregatingMessageGroupProcessor - Class in org.springframework.integration.aggregator

Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.

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

 

AbstractAmqpChannel - Class in org.springframework.integration.amqp.channel

The base AbstractMessageChannel implementation for AMQP.

AbstractAmqpOutboundEndpoint - Class in org.springframework.integration.amqp.outbound

A base AbstractReplyProducingMessageHandler extension for AMQP message handlers.

AbstractAmqpOutboundEndpoint() - Constructor for class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint

 

AbstractAmqpOutboundEndpoint.CorrelationDataWrapper - Class in org.springframework.integration.amqp.outbound

 

AbstractBatchingMessageGroupStore - Class in org.springframework.integration.store

 

AbstractBatchingMessageGroupStore() - Constructor for class org.springframework.integration.store.AbstractBatchingMessageGroupStore

 

AbstractByteArraySerializer - Class in org.springframework.integration.ip.tcp.serializer

Base class for (de)serializers that provide a mechanism to reconstruct a byte array from an arbitrary stream.

AbstractByteArraySerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer

 

AbstractCandidate - Class in org.springframework.integration.leader

Base implementation of a Candidate.

AbstractCandidate() - Constructor for class org.springframework.integration.leader.AbstractCandidate

Instantiate a abstract candidate.

AbstractCandidate(String, String) - Constructor for class org.springframework.integration.leader.AbstractCandidate

Instantiate a abstract candidate.

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

Base parser for Channel Adapters.

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

 

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

 

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

 

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

Base class for channel parsers.

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

 

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

Abstract class for client connection factories; client connection factories establish outgoing connections.

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

Construct a factory that will established connections to the host and port.

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

The abstract MongoDB AbstractMessageGroupStore implementation to provide configuration for common options for implementations of this class.

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

 

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

 

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

 

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

Base class for all connection factories.

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

 

AbstractConnectionFactory(String, int) - Constructor for class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

 

AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,​C>,​C extends AbstractConnectionFactory> - Class in org.springframework.integration.ip.dsl

An IntegrationComponentSpec for AbstractConnectionFactorys.

AbstractConnectionFactorySpec(C) - Constructor for class org.springframework.integration.ip.dsl.AbstractConnectionFactorySpec

 

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

Base class parser for elements that create Message Endpoints.

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

 

AbstractCorrelatingMessageHandler - Class in org.springframework.integration.aggregator

Abstract Message handler that holds a buffer of correlated messages in a MessageStore.

AbstractCorrelatingMessageHandler(MessageGroupProcessor) - Constructor for class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

 

AbstractCorrelatingMessageHandler(MessageGroupProcessor, MessageGroupStore) - Constructor for class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

 

AbstractCorrelatingMessageHandler(MessageGroupProcessor, MessageGroupStore, CorrelationStrategy, ReleaseStrategy) - Constructor for class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

 

AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup - Class in org.springframework.integration.aggregator

 

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

Base class for parsers that create an instance of AbstractCorrelatingMessageHandler.

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

 

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

A file list filter that can be configured to always accept (pass) directories.

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

 

AbstractDispatcher - Class in org.springframework.integration.dispatcher

Base class for MessageDispatcher implementations.

AbstractDispatcher() - Constructor for class org.springframework.integration.dispatcher.AbstractDispatcher

 

AbstractEndpoint - Class in org.springframework.integration.endpoint

The base class for Message Endpoint implementations.

AbstractEndpoint() - Constructor for class org.springframework.integration.endpoint.AbstractEndpoint

 

AbstractEvaluationContextFactoryBean - Class in org.springframework.integration.config

Abstract class for integration evaluation context factory beans.

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

 

AbstractExecutorChannel - Class in org.springframework.integration.channel

The AbstractSubscribableChannel base implementation for those inheritors which logic may be based on the Executor.

AbstractExecutorChannel(Executor) - Constructor for class org.springframework.integration.channel.AbstractExecutorChannel

 

AbstractExecutorChannel.MessageHandlingTask - Class in org.springframework.integration.channel

 

AbstractExpressionEvaluator - Class in org.springframework.integration.util

 

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

 

AbstractFetchLimitingMessageSource<T> - Class in org.springframework.integration.endpoint

A message source that can limit the number of remote objects it fetches.

AbstractFetchLimitingMessageSource() - Constructor for class org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource

 

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

Abstract implementation of FileInfo; provides a setter for the remote directory and a generic toString implementation.

AbstractFileInfo() - Constructor for class org.springframework.integration.file.remote.AbstractFileInfo

 

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

A convenience base class for any FileListFilter whose criteria can be evaluated against each File in isolation.

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

 

AbstractFileLockerFilter - Class in org.springframework.integration.file.locking

Convenience base class for implementing FileLockers that check a lock before accepting a file.

AbstractFileLockerFilter() - Constructor for class org.springframework.integration.file.locking.AbstractFileLockerFilter

 

AbstractFilePayloadTransformer<T> - Class in org.springframework.integration.file.transformer

Base class for transformers that convert a File payload.

AbstractFilePayloadTransformer() - Constructor for class org.springframework.integration.file.transformer.AbstractFilePayloadTransformer

 

AbstractFilePayloadTransformerParser - Class in org.springframework.integration.file.config

Base class for File payload transformer parsers.

AbstractFilePayloadTransformerParser() - Constructor for class org.springframework.integration.file.config.AbstractFilePayloadTransformerParser

 

AbstractFtpSessionFactory<T extends org.apache.commons.net.ftp.FTPClient> - Class in org.springframework.integration.ftp.session

Base class for FTP SessionFactory implementations.

AbstractFtpSessionFactory() - Constructor for class org.springframework.integration.ftp.session.AbstractFtpSessionFactory

 

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

The base HandleMessageAdvice for advices which can be applied only for the MessageHandler.handleMessage(Message).

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

 

AbstractHeaderMapper<T> - Class in org.springframework.integration.mapping

Abstract base class for RequestReplyHeaderMapper implementations.

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

Create a new instance.

AbstractHeaderMapper.CompositeHeaderMatcher - Class in org.springframework.integration.mapping

A composite AbstractHeaderMapper.HeaderMatcher that matches if one of provided AbstractHeaderMapper.HeaderMatchers matches to the headerName.

AbstractHeaderMapper.ContentBasedHeaderMatcher - Class in org.springframework.integration.mapping

A content-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header is contained within a list of candidates.

AbstractHeaderMapper.HeaderMatcher - Interface in org.springframework.integration.mapping

Strategy interface to determine if a given header name matches.

AbstractHeaderMapper.PatternBasedHeaderMatcher - Class in org.springframework.integration.mapping

A pattern-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header matches one of the specified simple patterns.

AbstractHeaderMapper.PrefixBasedMatcher - Class in org.springframework.integration.mapping

A prefix-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header starts with a configurable prefix.

AbstractHeaderMapper.SinglePatternBasedHeaderMatcher - Class in org.springframework.integration.mapping

A pattern-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header matches the specified simple pattern.

AbstractHeaderValueMessageProcessor<T> - Class in org.springframework.integration.transformer.support

 

AbstractHeaderValueMessageProcessor() - Constructor for class org.springframework.integration.transformer.support.AbstractHeaderValueMessageProcessor

 

AbstractHttpRequestExecutingMessageHandler - Class in org.springframework.integration.http.outbound

Base class for http outbound adapter/gateway.

AbstractHttpRequestExecutingMessageHandler(Expression) - Constructor for class org.springframework.integration.http.outbound.AbstractHttpRequestExecutingMessageHandler

 

AbstractInboundFileSynchronizer<F> - Class in org.springframework.integration.file.remote.synchronizer

Base class charged with knowing how to connect to a remote file system, scan it for new files and then download the files.

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

Create a synchronizer with the SessionFactory used to acquire Session instances.

AbstractInboundFileSynchronizingMessageSource<F> - Class in org.springframework.integration.file.remote.synchronizer

Factors out the common logic between the FTP and SFTP adapters.

AbstractInboundFileSynchronizingMessageSource(AbstractInboundFileSynchronizer<F>) - Constructor for class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource

 

AbstractInboundFileSynchronizingMessageSource(AbstractInboundFileSynchronizer<F>, Comparator<File>) - Constructor for class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource

 

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

Base class for inbound gateway parsers.

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

 

AbstractIntegrationMessageBuilder<T> - Class in org.springframework.integration.support

 

AbstractIntegrationMessageBuilder() - Constructor for class org.springframework.integration.support.AbstractIntegrationMessageBuilder

 

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

Base class for NamespaceHandlers that registers a BeanFactoryPostProcessor for configuring default bean definitions.

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

 

AbstractInternetProtocolReceivingChannelAdapter - Class in org.springframework.integration.ip

Base class for inbound TCP/UDP Channel Adapters.

AbstractInternetProtocolReceivingChannelAdapter(int) - Constructor for class org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter

 

AbstractInternetProtocolSendingMessageHandler - Class in org.springframework.integration.ip

Base class for UDP MessageHandlers.

AbstractInternetProtocolSendingMessageHandler(String, int) - Constructor for class org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler

 

AbstractJacksonJsonObjectMapper<N,​P,​J> - Class in org.springframework.integration.support.json

Base class for Jackson JsonObjectMapper implementations.

AbstractJacksonJsonObjectMapper() - Constructor for class org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper

 

AbstractJmsChannel - Class in org.springframework.integration.jms

 

AbstractJmsChannel(JmsTemplate) - Constructor for class org.springframework.integration.jms.AbstractJmsChannel

 

AbstractJpaOutboundGatewayParser - Class in org.springframework.integration.jpa.config.xml

The Abstract Parser for the JPA Outbound Gateways.

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

 

AbstractJsonInboundMessageMapper<P> - Class in org.springframework.integration.support.json

Abstract InboundMessageMapper implementation that maps incoming JSON messages to a Message with the specified payload type.

AbstractJsonInboundMessageMapper(Type) - Constructor for class org.springframework.integration.support.json.AbstractJsonInboundMessageMapper

 

AbstractKafkaChannel - Class in org.springframework.integration.kafka.channel

Abstract MessageChannel backed by an Apache Kafka topic.

AbstractKafkaChannel(KafkaOperations<?, ?>, String) - Constructor for class org.springframework.integration.kafka.channel.AbstractKafkaChannel

Construct an instance with the provided KafkaOperations and topic.

AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,​C>,​C extends AbstractKafkaChannel> - Class in org.springframework.integration.kafka.dsl

Spec for a message channel backed by an Apache Kafka topic.

AbstractKafkaChannelSpec() - Constructor for class org.springframework.integration.kafka.dsl.AbstractKafkaChannelSpec

 

AbstractKeyValueMessageStore - Class in org.springframework.integration.store

Base class for implementations of Key/Value style MessageGroupStore and MessageStore.

AbstractKeyValueMessageStore() - Constructor for class org.springframework.integration.store.AbstractKeyValueMessageStore

 

AbstractKeyValueMessageStore(String) - Constructor for class org.springframework.integration.store.AbstractKeyValueMessageStore

Construct an instance based on the provided prefix for keys to distinguish between different store instances in the same target key-value data base.

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

Base class for Codecs using Kryo.

AbstractKryoCodec() - Constructor for class org.springframework.integration.codec.kryo.AbstractKryoCodec

 

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

Base class for KryoRegistrar implementations.

AbstractKryoRegistrar() - Constructor for class org.springframework.integration.codec.kryo.AbstractKryoRegistrar

 

AbstractLeaderEvent - Class in org.springframework.integration.leader.event

Base ApplicationEvent class for leader based events.

AbstractLeaderEvent(Object) - Constructor for class org.springframework.integration.leader.event.AbstractLeaderEvent

Create a new ApplicationEvent.

AbstractLeaderEvent(Object, Context, String) - Constructor for class org.springframework.integration.leader.event.AbstractLeaderEvent

Create a new ApplicationEvent.

AbstractMailMessageTransformer<T> - Class in org.springframework.integration.mail.transformer

Base class for Transformers that convert from a JavaMail Message to a Spring Integration Message.

AbstractMailMessageTransformer() - Constructor for class org.springframework.integration.mail.transformer.AbstractMailMessageTransformer

 

AbstractMailReceiver - Class in org.springframework.integration.mail

Base class for MailReceiver implementations.

AbstractMailReceiver() - Constructor for class org.springframework.integration.mail.AbstractMailReceiver

 

AbstractMailReceiver(String) - Constructor for class org.springframework.integration.mail.AbstractMailReceiver

 

AbstractMailReceiver(URLName) - Constructor for class org.springframework.integration.mail.AbstractMailReceiver

 

AbstractMappingMessageRouter - Class in org.springframework.integration.router

Base class for all Message Routers that support mapping from arbitrary String values to Message Channel names.

AbstractMappingMessageRouter() - Constructor for class org.springframework.integration.router.AbstractMappingMessageRouter

 

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

A FileListFilter that only passes files matched by one or more FileListFilter if a corresponding marker file is also present to indicate a file transfer is complete.

AbstractMarkerFilePresentFileListFilter(Map<FileListFilter<F>, Function<String, String>>) - Constructor for class org.springframework.integration.file.filters.AbstractMarkerFilePresentFileListFilter

Construct an instance with a map of FileListFilter and functions be applied to the name of a matched file when looking for the marker file.

AbstractMarkerFilePresentFileListFilter(FileListFilter<F>) - Constructor for class org.springframework.integration.file.filters.AbstractMarkerFilePresentFileListFilter

Construct an instance with a single FileListFilter and ".complete" will be appended to the name of a matched file when looking for the marker file.

AbstractMarkerFilePresentFileListFilter(FileListFilter<F>, String) - Constructor for class org.springframework.integration.file.filters.AbstractMarkerFilePresentFileListFilter

Construct an instance with a single FileListFilter and a suffix that will will be appended to the name of a matched file when looking for the marker file.

AbstractMarkerFilePresentFileListFilter(FileListFilter<F>, Function<String, String>) - Constructor for class org.springframework.integration.file.filters.AbstractMarkerFilePresentFileListFilter

Construct an instance with a single FileListFilter and a function that will be applied to the name of a matched file when looking for the marker file.

AbstractMessageChannel - Class in org.springframework.integration.channel

Base class for MessageChannel implementations providing common properties such as the channel name.

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

 

AbstractMessageChannel.ChannelInterceptorList - Class in org.springframework.integration.channel

A convenience wrapper class for the list of ChannelInterceptors.

AbstractMessageGroupStore - Class in org.springframework.integration.store

 

AbstractMessageGroupStore() - Constructor for class org.springframework.integration.store.AbstractMessageGroupStore

 

AbstractMessageGroupStore(boolean) - Constructor for class org.springframework.integration.store.AbstractMessageGroupStore

 

AbstractMessageHandler - Class in org.springframework.integration.handler

Base class for MessageHandler implementations.

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

 

AbstractMessageListenerContainerSpec<S extends AbstractMessageListenerContainerSpec<S,​C>,​C extends AbstractMessageListenerContainer> - Class in org.springframework.integration.amqp.dsl

Base class for container specs.

AbstractMessageListenerContainerSpec(C) - Constructor for class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

 

AbstractMessageProcessingSelector - Class in org.springframework.integration.filter

A base class for MessageSelector implementations that delegate to a MessageProcessor.

AbstractMessageProcessingSelector(MessageProcessor<Boolean>) - Constructor for class org.springframework.integration.filter.AbstractMessageProcessingSelector

 

AbstractMessageProcessingTransformer - Class in org.springframework.integration.transformer

Base class for Message Transformers that delegate to a MessageProcessor.

AbstractMessageProcessingTransformer(MessageProcessor<?>) - Constructor for class org.springframework.integration.transformer.AbstractMessageProcessingTransformer

 

AbstractMessageProcessor<T> - Class in org.springframework.integration.handler

 

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

 

AbstractMessageProducingHandler - Class in org.springframework.integration.handler

The base AbstractMessageHandler implementation for the MessageProducer.

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

 

AbstractMessageRouter - Class in org.springframework.integration.router

Base class for all Message Routers.

AbstractMessageRouter() - Constructor for class org.springframework.integration.router.AbstractMessageRouter

 

AbstractMessageSource<T> - Class in org.springframework.integration.endpoint

Abstract message source.

AbstractMessageSource() - Constructor for class org.springframework.integration.endpoint.AbstractMessageSource

 

AbstractMessageSourceAdvice - Class in org.springframework.integration.aop

Deprecated.

since 5.3 in favor of MessageSourceMutator.

AbstractMessageSourceAdvice() - Constructor for class org.springframework.integration.aop.AbstractMessageSourceAdvice

Deprecated.

 

AbstractMessageSplitter - Class in org.springframework.integration.splitter

Base class for Message-splitting handlers.

AbstractMessageSplitter() - Constructor for class org.springframework.integration.splitter.AbstractMessageSplitter

 

AbstractMeter(MeterRegistry) - Constructor for class org.springframework.integration.support.management.micrometer.MicrometerMetricsCaptor.AbstractMeter

 

AbstractMethodAnnotationPostProcessor<T extends Annotation> - Class in org.springframework.integration.config.annotation

Base class for Method-level annotation post-processors.

AbstractMethodAnnotationPostProcessor(ConfigurableListableBeanFactory) - Constructor for class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

AbstractMongoDbMessageSource<T> - Class in org.springframework.integration.mongodb.inbound

An AbstractMessageSource extension for common MongoDB sources options and support methods.

AbstractMongoDbMessageSource(Expression) - Constructor for class org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource

 

AbstractMongoDbMessageSourceSpec<S extends AbstractMongoDbMessageSourceSpec<S,​H>,​H extends AbstractMongoDbMessageSource<?>> - Class in org.springframework.integration.mongodb.dsl

A MessageSourceSpec extension for common MongoDB sources options.

AbstractMongoDbMessageSourceSpec() - Constructor for class org.springframework.integration.mongodb.dsl.AbstractMongoDbMessageSourceSpec

 

AbstractMqttMessageDrivenChannelAdapter - Class in org.springframework.integration.mqtt.inbound

Abstract class for MQTT Message-Driven Channel Adapters.

AbstractMqttMessageDrivenChannelAdapter(String, String, String...) - Constructor for class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

 

AbstractMqttMessageHandler - Class in org.springframework.integration.mqtt.outbound

Abstract class for MQTT outbound channel adapters.

AbstractMqttMessageHandler(String, String) - Constructor for class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler

 

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

Base class for outbound Channel Adapter parsers.

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

 

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

Base class for url-based outbound gateway parsers.

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

 

AbstractPayloadTransformer<T,​U> - Class in org.springframework.integration.transformer

A base class for Transformer implementations that modify the payload of a Message.

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

 

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

Stores "seen" files in a MetadataStore to survive application restarts.

AbstractPersistentAcceptOnceFileListFilter(ConcurrentMetadataStore, String) - Constructor for class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter

 

AbstractPollableChannel - Class in org.springframework.integration.channel

Base class for all pollable channels.

AbstractPollableChannel() - Constructor for class org.springframework.integration.channel.AbstractPollableChannel

 

AbstractPollingEndpoint - Class in org.springframework.integration.endpoint

An AbstractEndpoint extension for Polling Consumer pattern basics.

AbstractPollingEndpoint() - Constructor for class org.springframework.integration.endpoint.AbstractPollingEndpoint

 

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

Base parser for inbound Channel Adapters that poll a source.

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

 

AbstractPooledBufferByteArraySerializer - Class in org.springframework.integration.ip.tcp.serializer

Base class for deserializers that cannot determine the buffer size needed.

AbstractPooledBufferByteArraySerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer

 

AbstractReactiveMessageHandler - Class in org.springframework.integration.handler

Base class for ReactiveMessageHandler implementations.

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

 

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

Filters a listing of files by qualifying their 'name' against a regular expression (an instance of Pattern).

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

 

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

 

AbstractRemoteFileInboundChannelAdapterParser - Class in org.springframework.integration.file.config

Abstract base class for parsing remote file inbound channel adapters.

AbstractRemoteFileInboundChannelAdapterParser() - Constructor for class org.springframework.integration.file.config.AbstractRemoteFileInboundChannelAdapterParser

 

AbstractRemoteFileOutboundGateway<F> - Class in org.springframework.integration.file.remote.gateway

Base class for Outbound Gateways that perform remote file operations.

AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F>, String, String) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance with the supplied remote file template, a command ('ls', 'get' etc), and an expression to determine the filename.

AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F>, AbstractRemoteFileOutboundGateway.Command, String) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance with the supplied remote file template, a command ('ls', 'get' etc), and an expression to determine the filename.

AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F>, MessageSessionCallback<F, ?>) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance with the supplied remote file template and callback for performing operations on the session.

AbstractRemoteFileOutboundGateway(SessionFactory<F>, String, String) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance with the supplied session factory, a command ('ls', 'get' etc), and an expression to determine the filename.

AbstractRemoteFileOutboundGateway(SessionFactory<F>, AbstractRemoteFileOutboundGateway.Command, String) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance with the supplied session factory, a command ('ls', 'get' etc), and an expression to determine the filename.

AbstractRemoteFileOutboundGateway(SessionFactory<F>, MessageSessionCallback<F, ?>) - Constructor for class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

Construct an instance using the provided session factory and callback for performing operations on the session.

AbstractRemoteFileOutboundGateway.Command - Enum in org.springframework.integration.file.remote.gateway

Enumeration of commands supported by the gateways.

AbstractRemoteFileOutboundGateway.Option - Enum in org.springframework.integration.file.remote.gateway

Enumeration of options supported by various commands.

AbstractRemoteFileOutboundGatewayParser - Class in org.springframework.integration.file.config

 

AbstractRemoteFileOutboundGatewayParser() - Constructor for class org.springframework.integration.file.config.AbstractRemoteFileOutboundGatewayParser

 

AbstractRemoteFileStreamingInboundChannelAdapterParser - Class in org.springframework.integration.file.config

Abstract base class for parsing remote file streaming inbound channel adapters.

AbstractRemoteFileStreamingInboundChannelAdapterParser() - Constructor for class org.springframework.integration.file.config.AbstractRemoteFileStreamingInboundChannelAdapterParser

 

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

A message source that produces a message with an InputStream payload referencing a remote file.

AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F>, Comparator<F>) - Constructor for class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource

 

AbstractReplyProducingMessageHandler - Class in org.springframework.integration.handler

Base class for MessageHandlers that are capable of producing replies.

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

 

AbstractReplyProducingMessageHandler.RequestHandler - Interface in org.springframework.integration.handler

An implementation of this interface is used to wrap the AbstractReplyProducingMessageHandler.handleRequestMessage(Message) method.

AbstractReplyProducingPostProcessingMessageHandler - Class in org.springframework.integration.handler

 

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

 

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

Base class for MessageHandler advice classes.

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

 

AbstractRequestHandlerAdvice.ExecutionCallback - Interface in org.springframework.integration.handler.advice

Called by subclasses in doInvoke() to proceed() the invocation.

AbstractRequestHandlerAdvice.ThrowableHolderException - Exception in org.springframework.integration.handler.advice

 

AbstractRequestResponseScenarioTests - Class in org.springframework.integration.test.support

Convenience class for testing Spring Integration request-response message scenarios.

AbstractRequestResponseScenarioTests() - Constructor for class org.springframework.integration.test.support.AbstractRequestResponseScenarioTests

 

AbstractResponseValidator<T> - Class in org.springframework.integration.test.support

The base class for response validators used for RequestResponseScenarios

AbstractResponseValidator() - Constructor for class org.springframework.integration.test.support.AbstractResponseValidator

 

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

Base parser for routers.

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

 

AbstractRouterSpec<S extends AbstractRouterSpec<S,​R>,​R extends AbstractMessageRouter> - Class in org.springframework.integration.dsl

A MessageHandlerSpec for AbstractMessageRouters.

AbstractRouterSpec(R) - Constructor for class org.springframework.integration.dsl.AbstractRouterSpec

 

AbstractRSocketConnector - Class in org.springframework.integration.rsocket

A base connector container for common RSocket client and server functionality.

AbstractRSocketConnector(IntegrationRSocketMessageHandler) - Constructor for class org.springframework.integration.rsocket.AbstractRSocketConnector

 

AbstractScriptExecutingMessageProcessor<T> - Class in org.springframework.integration.scripting

Base MessageProcessor for scripting implementations to extend.

AbstractScriptExecutingMessageProcessor() - Constructor for class org.springframework.integration.scripting.AbstractScriptExecutingMessageProcessor

 

AbstractScriptExecutingMessageProcessor(ScriptVariableGenerator) - Constructor for class org.springframework.integration.scripting.AbstractScriptExecutingMessageProcessor

 

AbstractScriptExecutor - Class in org.springframework.integration.scripting.jsr223

Base Class for ScriptExecutor.

AbstractScriptExecutor(String) - Constructor for class org.springframework.integration.scripting.jsr223.AbstractScriptExecutor

 

AbstractScriptExecutor(ScriptEngine) - Constructor for class org.springframework.integration.scripting.jsr223.AbstractScriptExecutor

 

AbstractScriptParser - Class in org.springframework.integration.scripting.config

 

AbstractScriptParser() - Constructor for class org.springframework.integration.scripting.config.AbstractScriptParser

 

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

Base class for all server connection factories.

AbstractServerConnectionFactory(int) - Constructor for class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory

The port on which the factory will listen.

AbstractSimpleMessageHandlerFactoryBean<H extends MessageHandler> - Class in org.springframework.integration.config

Factory bean to create and configure a MessageHandler.

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

 

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

Base class for filters that support ant style path expressions, which are less powerful but more readable than regular expressions.

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

 

AbstractStandardMessageHandlerFactoryBean - Class in org.springframework.integration.config

Base class for FactoryBeans that create standard MessageHandler instances.

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

 

AbstractStompSessionManager - Class in org.springframework.integration.stomp

Base StompSessionManager implementation to manage a single StompSession over its ListenableFuture from the target implementation of this class.

AbstractStompSessionManager(StompClientSupport) - Constructor for class org.springframework.integration.stomp.AbstractStompSessionManager

 

AbstractSubscribableChannel - Class in org.springframework.integration.channel

Base implementation of MessageChannel that invokes the subscribed handler(s) by delegating to a MessageDispatcher.

AbstractSubscribableChannel() - Constructor for class org.springframework.integration.channel.AbstractSubscribableChannel

 

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

Base class for TCP Connection Support implementations.

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

 

AbstractTransformer - Class in org.springframework.integration.transformer

A base class for Transformer implementations.

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

 

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

 

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

 

AbstractUdpOutboundChannelAdapterSpec<S extends AbstractUdpOutboundChannelAdapterSpec<S>> - Class in org.springframework.integration.ip.dsl

A MessageHandlerSpec for UDP MessageHandlers.

AbstractUdpOutboundChannelAdapterSpec() - Constructor for class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

 

AbstractUdpOutboundChannelAdapterSpec(String) - Constructor for class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

 

AbstractUdpOutboundChannelAdapterSpec(String, int) - Constructor for class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

 

AbstractUdpOutboundChannelAdapterSpec(Function<Message<?>, ?>) - Constructor for class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

 

AbstractWebServiceInboundGateway - Class in org.springframework.integration.ws

 

AbstractWebServiceInboundGateway() - Constructor for class org.springframework.integration.ws.AbstractWebServiceInboundGateway

 

AbstractWebServiceOutboundGateway - Class in org.springframework.integration.ws

Base class for outbound Web Service-invoking Messaging Gateways.

AbstractWebServiceOutboundGateway(String, WebServiceMessageFactory) - Constructor for class org.springframework.integration.ws.AbstractWebServiceOutboundGateway

 

AbstractWebServiceOutboundGateway(DestinationProvider, WebServiceMessageFactory) - Constructor for class org.springframework.integration.ws.AbstractWebServiceOutboundGateway

 

AbstractWebServiceOutboundGateway.RequestMessageCallback - Class in org.springframework.integration.ws

 

AbstractWebServiceOutboundGateway.ResponseMessageExtractor - Class in org.springframework.integration.ws

 

AbstractXmlTransformer - Class in org.springframework.integration.xml.transformer

Super class for XML transformers.

AbstractXmlTransformer() - Constructor for class org.springframework.integration.xml.transformer.AbstractXmlTransformer

 

AbstractXmppConnectionAwareEndpoint - Class in org.springframework.integration.xmpp.core

 

AbstractXmppConnectionAwareEndpoint() - Constructor for class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareEndpoint

 

AbstractXmppConnectionAwareEndpoint(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareEndpoint

 

AbstractXmppConnectionAwareMessageHandler - Class in org.springframework.integration.xmpp.core

 

AbstractXmppConnectionAwareMessageHandler() - Constructor for class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareMessageHandler

 

AbstractXmppConnectionAwareMessageHandler(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.core.AbstractXmppConnectionAwareMessageHandler

 

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

Base class for XMPP inbound parsers

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

 

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

Base class of XMPP outbound parsers

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

 

AbstractXPathMessageSelector - Class in org.springframework.integration.xml.selector

Base class for XPath MessageSelector implementations.

AbstractXPathMessageSelector(String) - Constructor for class org.springframework.integration.xml.selector.AbstractXPathMessageSelector

 

AbstractXPathMessageSelector(String, String, String) - Constructor for class org.springframework.integration.xml.selector.AbstractXPathMessageSelector

 

AbstractXPathMessageSelector(String, Map<String, String>) - Constructor for class org.springframework.integration.xml.selector.AbstractXPathMessageSelector

 

AbstractXPathMessageSelector(XPathExpression) - Constructor for class org.springframework.integration.xml.selector.AbstractXPathMessageSelector

 

accept(F) - Method in class org.springframework.integration.file.filters.AbstractFileListFilter

Subclasses must implement this method.

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

 

accept(F) - Method in class org.springframework.integration.file.filters.AbstractRegexPatternFileListFilter

 

accept(F) - Method in class org.springframework.integration.file.filters.AbstractSimplePatternFileListFilter

Accept the given file if its name matches the pattern.

accept(F) - Method in class org.springframework.integration.file.filters.AcceptAllFileListFilter

 

accept(F) - Method in class org.springframework.integration.file.filters.AcceptOnceFileListFilter

 

accept(F) - Method in class org.springframework.integration.file.filters.ChainFileListFilter

 

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

 

accept(F) - Method in class org.springframework.integration.file.filters.ExpressionFileListFilter

 

accept(F) - Method in interface org.springframework.integration.file.filters.FileListFilter

Filter a single file; only called externally if FileListFilter.supportsSingleFileFiltering() returns true.

accept(File) - Method in class org.springframework.integration.file.filters.IgnoreHiddenFileListFilter

 

accept(File) - Method in class org.springframework.integration.file.filters.LastModifiedFileListFilter

 

accept(File) - Method in class org.springframework.integration.file.locking.AbstractFileLockerFilter

 

accept(ObjectName, String) - Method in class org.springframework.integration.jmx.DefaultMBeanAttributeFilter

 

accept(ObjectName, String) - Method in interface org.springframework.integration.jmx.MBeanAttributeFilter

 

accept(ObjectName, String) - Method in class org.springframework.integration.jmx.NamedFieldsMBeanAttributeFilter

 

accept(ObjectName, String) - Method in class org.springframework.integration.jmx.NotNamedFieldsMBeanAttributeFilter

 

accept(AcknowledgmentCallback) - Static method in class org.springframework.integration.acks.AckUtils

ACCEPT the associated message if the callback is not null.

accept(Message<?>) - Method in interface org.springframework.integration.core.MessageSelector

 

accept(Message<?>) - Method in class org.springframework.integration.filter.AbstractMessageProcessingSelector

 

accept(Message<?>) - Method in class org.springframework.integration.router.RecipientListRouter.Recipient

 

accept(Message<?>) - Method in class org.springframework.integration.selector.MessageSelectorChain

Pass the message through the selector chain.

accept(Message<?>) - Method in class org.springframework.integration.selector.MetadataStoreSelector

 

accept(Message<?>) - Method in class org.springframework.integration.selector.PayloadTypeSelector

 

accept(Message<?>) - Method in class org.springframework.integration.selector.UnexpiredMessageSelector

 

accept(Message<?>) - Method in class org.springframework.integration.xml.selector.BooleanTestXPathMessageSelector

Return true if the XPathExpression evaluates to true

accept(Message<?>) - Method in class org.springframework.integration.xml.selector.RegexTestXPathMessageSelector

Evaluate the payload and return true if the value returned by the XPathExpression matches the regex.

accept(Message<?>) - Method in class org.springframework.integration.xml.selector.StringValueTestXPathMessageSelector

Evaluate the payload and return true if the value returned by the XPathExpression is equal to the valueToTestFor.

accept(Message<?>) - Method in class org.springframework.integration.xml.selector.XmlValidatingMessageSelector

 

accept(S) - Method in interface org.springframework.integration.core.GenericSelector

 

ACCEPT - org.springframework.integration.acks.AcknowledgmentCallback.Status

Mark the message as accepted.

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

Simple implementation of FileListFilter that always returns true.

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

 

acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.integration.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the condition is true.

acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke BiConsumer.accept(Object, Object) with the arguments if the condition is true.

acceptIfCondition(boolean, T, Consumer<T>) - Method in class org.springframework.integration.JavaUtils

Invoke Consumer.accept(Object) with the value if the condition is true.

acceptIfCondition(boolean, T, Consumer<T>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke Consumer.accept(Object) with the value if the condition is true.

acceptIfHasText(String, Consumer<String>) - Method in class org.springframework.integration.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfHasText(String, Consumer<String>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfHasText(T, String, BiConsumer<T, String>) - Method in class org.springframework.integration.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the value argument is not null or empty.

acceptIfHasText(T, String, BiConsumer<T, String>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke BiConsumer.accept(Object, Object) with the arguments if the value argument is not null or empty.

acceptIfNotEmpty(List<T>, Consumer<List<T>>) - Method in class org.springframework.integration.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotEmpty(List<T>, Consumer<List<T>>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotEmpty(T[], Consumer<T[]>) - Method in class org.springframework.integration.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotEmpty(T[], Consumer<T[]>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.integration.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the t2 argument is not null.

acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke BiConsumer.accept(Object, Object) with the arguments if the t2 argument is not null.

acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.integration.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null.

acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.integration.util.JavaUtils

Deprecated.

Invoke Consumer.accept(Object) with the value if it is not null.

acceptMessagesWhileStopping(boolean) - Method in class org.springframework.integration.jms.dsl.JmsListenerContainerSpec

 

acceptMessagesWhileStopping(boolean) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec

 

AcceptOnceCollectionFilter<T> - Class in org.springframework.integration.util

An implementation of CollectionFilter that remembers the elements passed in the previous invocation in order to avoid returning those elements more than once.

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

 

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

FileListFilter that passes files only one time.

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

Creates an AcceptOnceFileListFilter based on an unbounded queue.

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

Creates an AcceptOnceFileListFilter that is based on a bounded queue.

ACK - Static variable in class org.springframework.integration.stomp.support.IntegrationStompHeaders

 

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

The remote ip address to which UDP application-level acks will be sent.

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

A correlation id for UDP application-level acks.

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

Set the number of outstanding record count after which offsets should be committed when ContainerProperties.AckMode.COUNT or ContainerProperties.AckMode.COUNT_TIME is being used.

ackCounter(int) - Method in class org.springframework.integration.ip.dsl.AbstractUdpOutboundChannelAdapterSpec

 

ackDiscarded(boolean) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec

A boolean flag to indicate if FilteringMessageListenerAdapter should acknowledge discarded records or not.

ackMode(ContainerProperties.AckMode) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Set the ack mode to use when auto ack (in the configuration properties) is false.

acknowledge() - Method in interface org.springframework.integration.acks.AcknowledgmentCallback

 

acknowledge() - Method in interface org.springframework.integration.acks.SimpleAcknowledgment

Acknowledge the message delivery.

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

 

acknowledge(AcknowledgmentCallback.Status) - Method in interface org.springframework.integration.acks.AcknowledgmentCallback

Acknowledge the message.

acknowledge(AcknowledgmentCallback.Status) - Method in class org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallback

 

acknowledge(AcknowledgmentCallback.Status) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback

 

acknowledgeMode(AcknowledgeMode) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

 

acknowledgeMode(AcknowledgeMode) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

 

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

A callback to acknowledge message delivery.

AcknowledgmentCallback - Interface in org.springframework.integration.acks

A general abstraction over acknowledgments.

AcknowledgmentCallback.Status - Enum in org.springframework.integration.acks

 

AcknowledgmentCallbackFactory<T> - Interface in org.springframework.integration.acks

A factory for creating AcknowledgmentCallbacks.

ackTime(long) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Set the time (ms) after which outstanding offsets should be committed when ContainerProperties.AckMode.TIME or ContainerProperties.AckMode.COUNT_TIME is being used.

ackTimeout(long) - Method in class org.springframework.integration.amqp.dsl.DirectMessageListenerContainerSpec

 

AckUtils - Class in org.springframework.integration.acks

Utility methods for acting on AcknowledgmentCallback headers.

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

 

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

 

activeCount - Variable in class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

 

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

For information only - when using a cached or failover client connection factory, contains the actual underlying connection id.

add(int, Properties) - Method in class org.springframework.integration.history.MessageHistory

 

add(int, MessageSelector) - Method in class org.springframework.integration.selector.MessageSelectorChain

Add a selector to the chain at the specified index.

add(int, ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

 

add(String, PropertyAccessor) - Method in class org.springframework.integration.expression.SpelPropertyAccessorRegistrar

Add the provided named property accessor.

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

 

add(PropertyAccessor...) - Method in class org.springframework.integration.expression.SpelPropertyAccessorRegistrar

Add the provided property accessors.

add(MessageSelector) - Method in class org.springframework.integration.selector.MessageSelectorChain

Add a selector to the end of the chain.

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

Add the message to this group.

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

 

add(ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

 

addAll(int, Collection<? extends Properties>) - Method in class org.springframework.integration.history.MessageHistory

 

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

 

addAllowedPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore

Add patterns for packages/classes that are allowed to be deserialized.

addAllowedPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore

Add patterns for packages/classes that are allowed to be deserialized.

addAllowedPatterns(String...) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore

Add patterns for packages/classes that are allowed to be deserialized.

addAllowedPatterns(String...) - Method in class org.springframework.integration.mongodb.support.BinaryToMessageConverter

Add patterns for packages/classes that are allowed to be deserialized.

addAllowedPatterns(String...) - Method in class org.springframework.integration.support.converter.AllowListDeserializingConverter

Add package/class patterns to the allow list.

addAttribute(String, Object) - Method in class org.springframework.integration.transaction.IntegrationResourceHolder

Add attribute to this ResourceHolder instance.

addBean(Object) - Method in interface org.springframework.integration.dsl.context.IntegrationFlowContext.IntegrationFlowRegistrationBuilder

Add an object which will be registered as an IntegrationFlow dependant bean in the application context.

addBean(Object) - Method in class org.springframework.integration.dsl.context.StandardIntegrationFlowContext.StandardIntegrationFlowRegistrationBuilder

Add an object which will be registered as an IntegrationFlow dependant bean in the application context.

addBean(String, Object) - Method in interface org.springframework.integration.dsl.context.IntegrationFlowContext.IntegrationFlowRegistrationBuilder

Add an object which will be registered as an IntegrationFlow dependant bean in the application context.

addBean(String, Object) - Method in class org.springframework.integration.dsl.context.StandardIntegrationFlowContext.StandardIntegrationFlowRegistrationBuilder

Add an object which will be registered as an IntegrationFlow dependant bean in the application context.

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

 

addComponent(Object, String) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

 

addComponents(Map<Object, String>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

 

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

 

addConstructorValueIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.integration.ip.config.IpAdapterParserUtils

Adds a constructor-arg to the provided bean definition builder with the value of the attribute whose name is provided if that attribute is defined in the given element.

addCustomHeaders(TcpConnection, MessageHeaders) - Method in class org.springframework.integration.ip.tcp.connection.TcpMessageMapper

 

addDelayProperty(Message<?>, Message) - Method in class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint

 

addDestination(String...) - Method in class org.springframework.integration.stomp.inbound.StompInboundChannelAdapter

Add a destination (or destinations) to the subscribed list and subscribe it.

addDestinationConfigToConstructor(Element, BeanDefinitionBuilder, ParserContext) - Static method in class org.springframework.integration.ip.config.IpAdapterParserUtils

Adds destination configuration to constructor.

addDiscardCallback(Consumer<F>) - Method in class org.springframework.integration.file.filters.CompositeFileListFilter

 

addDiscardCallback(Consumer<F>) - Method in interface org.springframework.integration.file.filters.DiscardAwareFileListFilter

 

addDiscardCallback(Consumer<File>) - Method in class org.springframework.integration.file.filters.LastModifiedFileListFilter

 

addElementToHeaderMapping(String, String) - Method in class org.springframework.integration.config.xml.HeaderEnricherParserSupport

 

addElementToHeaderMapping(String, String, String) - Method in class org.springframework.integration.config.xml.HeaderEnricherParserSupport

 

addEndpoint(IntegrationRSocketEndpoint) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector

Add an IntegrationRSocketEndpoint for mapping and handling RSocket requests.

addFilter(FileListFilter<F>) - Method in class org.springframework.integration.file.filters.CompositeFileListFilter

 

addFilters(Collection<? extends FileListFilter<F>>) - Method in class org.springframework.integration.file.filters.CompositeFileListFilter

Add the new filters to this CompositeFileListFilter while maintaining the existing filters.

addFilters(FileListFilter<F>...) - Method in class org.springframework.integration.file.filters.CompositeFileListFilter

 

addHandler(MessageHandler) - Method in class org.springframework.integration.dispatcher.AbstractDispatcher

Add the handler to the internal Set.

addHandler(MessageHandler) - Method in interface org.springframework.integration.dispatcher.MessageDispatcher

Add a message handler.

addHeaders(Message<?>, Map<String, Object>) - Method in class org.springframework.integration.file.splitter.FileSplitter

 

addHeaders(Message<?>, Map<String, Object>) - Method in class org.springframework.integration.splitter.AbstractMessageSplitter

Allows subclasses to add extra headers to the output messages.

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.amqp.channel.PollableAmqpChannel

 

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractExecutorChannel

 

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractMessageChannel

Add a channel interceptor to the specified index of the list.

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractPollableChannel

 

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.jms.PollableJmsChannel

 

addInterceptor(int, ChannelInterceptor) - Method in class org.springframework.integration.kafka.channel.PollableKafkaChannel

 

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.amqp.channel.PollableAmqpChannel

 

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractExecutorChannel

 

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractMessageChannel

Add a channel interceptor to the end of the list.

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.channel.AbstractPollableChannel

 

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.jms.PollableJmsChannel

 

addInterceptor(ChannelInterceptor) - Method in class org.springframework.integration.kafka.channel.PollableKafkaChannel

 

addLifecyclesToRole(String, List<String>) - Method in class org.springframework.integration.support.SmartLifecycleRoleController

Add a SmartLifecycle beans to the role using their names.

addLifecycleToRole(String, String) - Method in class org.springframework.integration.support.SmartLifecycleRoleController

Add a SmartLifecycle bean to the role using its name.

addLifecycleToRole(String, SmartLifecycle) - Method in class org.springframework.integration.support.SmartLifecycleRoleController

Add a SmartLifecycle to the role.

addListener(MetadataStoreListener) - Method in class org.springframework.integration.gemfire.metadata.GemfireMetadataStore

 

addListener(MetadataStoreListener) - Method in interface org.springframework.integration.metadata.ListenableMetadataStore

Register a listener with the metadata store.

addListener(MetadataStoreListener) - Method in class org.springframework.integration.zookeeper.metadata.ZookeeperMetadataStore

 

addMatchingInterceptors(InterceptableChannel, String) - Method in class org.springframework.integration.config.GlobalChannelInterceptorProcessor

Add any interceptor whose pattern matches against the channel's name.

addMessage(Message<T>) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore

 

addMessage(Message<T>) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

 

addMessage(Message<T>) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore

 

addMessage(Message<T>) - Method in class org.springframework.integration.store.AbstractKeyValueMessageStore

 

addMessage(Message<T>) - Method in interface org.springframework.integration.store.MessageStore

Put the provided Message into the MessageStore.

addMessage(Message<T>) - Method in class org.springframework.integration.store.SimpleMessageStore

 

addMessageDocument(MessageDocument) - Method in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.store.AbstractKeyValueMessageStore

 

addMessagesToGroup(Object, Message<?>...) - Method in interface org.springframework.integration.store.MessageGroupStore

Store messages with an association to a group id.

addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.store.SimpleMessageStore

 

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore

Store a message in the database.

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

 

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.mongodb.store.MongoDbChannelMessageStore

 

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.redis.store.RedisChannelMessageStore

 

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.redis.store.RedisChannelPriorityMessageStore

 

addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.store.AbstractMessageGroupStore

 

addMessageToGroup(Object, Message<?>) - Method in interface org.springframework.integration.store.BasicMessageGroupStore

Store a message with an association to a group id.

addMessagingAnnotationPostProcessor(Class<A>, MethodAnnotationPostProcessor<A>) - Method in class org.springframework.integration.config.annotation.MessagingAnnotationPostProcessor

 

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

 

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

When we are using sockets owned by a TcpListener, this method is called each time a new connection is made.

addNewConnection(TcpConnection) - Method in class org.springframework.integration.ip.tcp.TcpInboundGateway

 

addNewConnection(TcpConnection) - Method in class org.springframework.integration.ip.tcp.TcpOutboundGateway

 

addNewConnection(TcpConnection) - Method in class org.springframework.integration.ip.tcp.TcpSendingMessageHandler

 

addNotPropagatedHeaders(String...) - Method in class org.springframework.integration.handler.AbstractMessageProducingHandler

Add header patterns ("xxx*", "*xxx", "*xxx*" or "xxx*yyy") that will NOT be copied from the inbound message if AbstractMessageProducingHandler.shouldCopyRequestHeaders() is true, instead of overwriting the existing set.

addNotPropagatedHeaders(String...) - Method in interface org.springframework.integration.handler.HeaderPropagationAware

Add headers that will NOT be copied from the inbound message if the handler is configured to copy headers, instead of overwriting the existing set.

addNotPropagatedHeaders(String...) - Method in class org.springframework.integration.transformer.MessageTransformingHandler

 

addPatternMapping(Pattern, ChannelAccessPolicy) - Method in class org.springframework.integration.security.channel.ChannelSecurityMetadataSource

 

addProperties(Map<String, Object>) - Method in class org.springframework.integration.graph.IntegrationNode

Add extra property to the node.

addProperty(String, Object) - Method in class org.springframework.integration.graph.IntegrationNode

Add extra property to the node.

addQueueNames(String...) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

 

addQueues(Queue...) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

 

addReadOnlyHeaders(String...) - Method in class org.springframework.integration.support.DefaultMessageBuilderFactory

Add headers to the configured list of read only headers.

addRecipient(String) - Method in class org.springframework.integration.router.RecipientListRouter

 

addRecipient(String) - Method in interface org.springframework.integration.router.RecipientListRouterManagement

Add a recipient with channelName.

addRecipient(String, String) - Method in class org.springframework.integration.router.RecipientListRouter

 

addRecipient(String, String) - Method in interface org.springframework.integration.router.RecipientListRouterManagement

Add a recipient with channelName and expression.

addRecipient(String, MessageSelector) - Method in class org.springframework.integration.router.RecipientListRouter

 

addRecipient(MessageChannel) - Method in class org.springframework.integration.router.RecipientListRouter

 

addRecipient(MessageChannel, MessageSelector) - Method in class org.springframework.integration.router.RecipientListRouter

 

addSessionFactory(Object, SessionFactory<F>) - Method in class org.springframework.integration.file.remote.session.DefaultSessionFactoryLocator

Add a session factory.

addSessionFactory(String, SessionFactory<F>) - Method in class org.springframework.integration.file.remote.session.DefaultSessionFactoryLocator

Deprecated.

since 5.3 in favor of DefaultSessionFactoryLocator.addSessionFactory(Object, SessionFactory)

addStandardHeaders(TcpConnection, MessageHeaders) - Method in class org.springframework.integration.ip.tcp.connection.TcpMessageMapper

 

addSupportedProtocols(String...) - Method in class org.springframework.integration.websocket.IntegrationWebSocketContainer

 

addTopic(String...) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

Add a topic (or topics) to the subscribed list (qos=1).

addTopic(String, int) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

Add a topic to the subscribed list.

addTopic(String, int) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter

 

addTopic(String, int) - Method in class org.springframework.integration.mqtt.inbound.Mqttv5PahoMessageDrivenChannelAdapter

 

addTopics(String[], int[]) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

Add topics to the subscribed list.

adjustLogLevels(String, List<Class<?>>, List<String>, Level) - Static method in class org.springframework.integration.test.util.TestUtils

 

advice(Advice...) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

 

advice(Advice...) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec

Configure a list of Advice objects to be applied, in nested order, to the endpoint's handler.

advice(Advice...) - Method in class org.springframework.integration.dsl.PollerSpec

Specify AOP Advices for the pollingTask.

adviceChain - Variable in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

 

adviceChain - Variable in class org.springframework.integration.dsl.ConsumerEndpointSpec

 

adviceChain() - Method in annotation type org.springframework.integration.annotation.Filter

Specify a "chain" of Advice beans that will "wrap" the message handler.

adviceChain() - Method in annotation type org.springframework.integration.annotation.ServiceActivator

Specify a "chain" of Advice beans that will "wrap" the message handler.

adviceChain() - Method in annotation type org.springframework.integration.annotation.Splitter

Specify a "chain" of Advice beans that will "wrap" the message handler.

adviceChain() - Method in annotation type org.springframework.integration.annotation.Transformer

Specify a "chain" of Advice objects that will "wrap" the message handler.

adviceChain(Advice...) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

 

adviceChain(Advice...) - Method in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec

Configure a chain of Advice objects for message delivery, applied to the downstream flow.

AdviceMessage<T> - Class in org.springframework.integration.message

A message implementation that is produced by an advice after successful message handling.

AdviceMessage(T, Map<String, Object>, Message<?>) - Constructor for class org.springframework.integration.message.AdviceMessage

 

AdviceMessage(T, Message<?>) - Constructor for class org.springframework.integration.message.AdviceMessage

 

AdviceMessage(T, MessageHeaders, Message<?>) - Constructor for class org.springframework.integration.message.AdviceMessage

A constructor with the MessageHeaders instance to use.

AdviceMessageJacksonDeserializer - Class in org.springframework.integration.support.json

The MessageJacksonDeserializer implementation for the AdviceMessage.

AdviceMessageJacksonDeserializer() - Constructor for class org.springframework.integration.support.json.AdviceMessageJacksonDeserializer

 

afterAll(ExtensionContext) - Method in class org.springframework.integration.test.condition.LogLevelsCondition

 

afterCommit(Object) - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource

 

afterCommit(String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterCommit(String, String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterCommit(String, MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterCommit(MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterEach(ExtensionContext) - Method in class org.springframework.integration.test.condition.LogLevelsCondition

 

afterMessageHandled(Message<?>, MessageChannel, MessageHandler, Exception) - Method in class org.springframework.integration.channel.interceptor.ThreadStatePropagationChannelInterceptor

 

afterMessageHandled(Message<?>, MessageChannel, MessageHandler, Exception) - Method in class org.springframework.integration.security.channel.SecurityContextPropagationChannelInterceptor

 

afterPropertiesSet() - Method in class org.springframework.integration.config.annotation.MessagingAnnotationPostProcessor

 

afterPropertiesSet() - Method in class org.springframework.integration.config.ChannelInitializer

 

afterPropertiesSet() - Method in class org.springframework.integration.config.ConsumerEndpointFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.CorrelationStrategyFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.IntegrationEvaluationContextFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.IntegrationSimpleEvaluationContextFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.ReleaseStrategyFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.config.SpelFunctionFactoryBean

 

afterPropertiesSet() - Method in class org.springframework.integration.context.IntegrationObjectSupport

 

afterPropertiesSet() - Method in class org.springframework.integration.file.remote.RemoteFileTemplate

 

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

 

afterPropertiesSet() - Method in class org.springframework.integration.ftp.server.ApacheMinaFtplet

 

afterPropertiesSet() - Method in class org.springframework.integration.groovy.GroovyScriptExecutingMessageProcessor

 

afterPropertiesSet() - Method in class org.springframework.integration.http.inbound.IntegrationRequestMappingHandlerMapping

 

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

 

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

 

afterPropertiesSet() - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore

 

afterPropertiesSet() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore

Check mandatory properties (DataSource and JdbcChannelMessageStore.setChannelMessageStoreQueryProvider(ChannelMessageStoreQueryProvider)).

afterPropertiesSet() - Method in class org.springframework.integration.jdbc.StoredProcExecutor

Verifies parameters, sets the parameters on SimpleJdbcCallOperations and ensures the appropriate SqlParameterSourceFactory is defined when ProcedureParameter are passed in.

afterPropertiesSet() - Method in class org.springframework.integration.jms.ChannelPublishingJmsMessageListener

 

afterPropertiesSet() - Method in class org.springframework.integration.jpa.core.JpaExecutor

Verify and sets the parameters.

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

 

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

 

afterPropertiesSet() - Method in class org.springframework.integration.mongodb.store.MongoDbChannelMessageStore

 

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

 

afterPropertiesSet() - Method in class org.springframework.integration.redis.outbound.ExpressionArgumentsStrategy

 

afterPropertiesSet() - Method in class org.springframework.integration.redis.store.RedisChannelMessageStore

 

afterPropertiesSet() - Method in class org.springframework.integration.routingslip.ExpressionEvaluatingRoutingSlipRouteStrategy

 

afterPropertiesSet() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector

 

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

 

afterPropertiesSet() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector

 

afterPropertiesSet() - Method in class org.springframework.integration.sftp.server.ApacheMinaSftpEventListener

 

afterPropertiesSet() - Method in class org.springframework.integration.store.MessageGroupStoreReaper

 

afterPropertiesSet() - Method in class org.springframework.integration.support.converter.ConfigurableCompositeMessageConverter

 

afterPropertiesSet() - Method in class org.springframework.integration.util.AbstractExpressionEvaluator

 

afterPropertiesSet() - Method in class org.springframework.integration.webflux.inbound.WebFluxIntegrationRequestMappingHandlerMapping

 

afterPropertiesSet() - Method in class org.springframework.integration.zeromq.ZeroMqProxy

 

afterPropertiesSet() - Method in class org.springframework.integration.zookeeper.config.LeaderInitiatorFactoryBean

 

afterReceive(boolean, MessageSource<?>) - Method in interface org.springframework.integration.file.remote.aop.RotationPolicy

Invoked after the message source receive() method.

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

 

afterReceive(Message<?>, Object) - Method in class org.springframework.integration.aop.CompoundTriggerAdvice

 

afterReceive(Message<?>, Object) - Method in interface org.springframework.integration.aop.MessageSourceMutator

 

afterReceive(Message<?>, Object) - Method in interface org.springframework.integration.aop.ReceiveMessageAdvice

Subclasses can take actions based on the result of the Joinpoint.proceed(); e.g.

afterReceive(Message<?>, Object) - Method in class org.springframework.integration.aop.SimpleActiveIdleReceiveMessageAdvice

 

afterReceive(Message<?>, MessageSource<?>) - Method in class org.springframework.integration.aop.CompoundTriggerAdvice

Deprecated.

since 5.3 in favor of CompoundTriggerAdvice.afterReceive(Message, Object)

afterReceive(Message<?>, MessageSource<?>) - Method in interface org.springframework.integration.aop.MessageSourceMutator

Subclasses can take actions based on the result of the poll; e.g.

afterReceive(Message<?>, MessageSource<?>) - Method in class org.springframework.integration.aop.SimpleActiveIdleMessageSourceAdvice

Deprecated.

 

afterReceive(Message<?>, MessageSource<?>) - Method in class org.springframework.integration.file.remote.aop.RotatingServerAdvice

 

afterReceiveCompletion(Message<?>, MessageChannel, Exception, Deque<ChannelInterceptor>) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

 

afterReceivePostProcessors(MessagePostProcessor...) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec

Set MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.

afterRelease(MessageGroup, Collection<Message<?>>) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

Allows you to provide additional logic that needs to be performed after the MessageGroup was released.

afterRelease(MessageGroup, Collection<Message<?>>) - Method in class org.springframework.integration.aggregator.AggregatingMessageHandler

Complete the group and remove all its messages.

afterRelease(MessageGroup, Collection<Message<?>>) - Method in class org.springframework.integration.aggregator.ResequencingMessageHandler

 

afterRelease(MessageGroup, Collection<Message<?>>, boolean) - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler

Subclasses may override if special action is needed because the group was released or discarded due to a timeout.

afterRelease(MessageGroup, Collection<Message<?>>, boolean) - Method in class org.springframework.integration.aggregator.ResequencingMessageHandler

Perform group removal if its size is equal to the sequenceSize.

afterRollback(Object) - Method in class org.springframework.integration.redis.inbound.RedisStoreMessageSource

 

afterRollback(String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterRollback(String, String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterRollback(String, MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterRollback(MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

afterSendCompletion(Message<?>, MessageChannel, boolean, Exception, Deque<ChannelInterceptor>) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList

 

afterSessionEnded(WebSocketSession, CloseStatus) - Method in class org.springframework.integration.websocket.inbound.WebSocketInboundChannelAdapter

 

afterSessionEnded(WebSocketSession, CloseStatus) - Method in interface org.springframework.integration.websocket.WebSocketListener

Invoked after a WebSocketSession has ended.

afterSessionEnded(WebSocketSession, CloseStatus, MessageChannel) - Method in class org.springframework.integration.websocket.support.PassThruSubProtocolHandler

 

afterSessionStarted(WebSocketSession) - Method in class org.springframework.integration.websocket.inbound.WebSocketInboundChannelAdapter

 

afterSessionStarted(WebSocketSession) - Method in interface org.springframework.integration.websocket.WebSocketListener

Invoked after a WebSocketSession has started.

afterSessionStarted(WebSocketSession, MessageChannel) - Method in class org.springframework.integration.websocket.support.PassThruSubProtocolHandler

 

afterShutdown() - Method in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter

 

afterShutdown() - Method in interface org.springframework.integration.context.OrderlyShutdownCapable

Called after normal shutdown of schedulers, executors etc, and after the shutdown delay has elapsed, but before any forced shutdown of any remaining active scheduler/executor threads.Can optionally return the number of active messages still in process.

afterShutdown() - Method in class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

 

afterShutdown() - Method in class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory

 

afterShutdown() - Method in class org.springframework.integration.ip.tcp.TcpInboundGateway

 

afterShutdown() - Method in class org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter

 

afterShutdown() - Method in class org.springframework.integration.jms.JmsInboundGateway

 

afterShutdown() - Method in class org.springframework.integration.jms.JmsMessageDrivenEndpoint

 

afterShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaInboundGateway

 

afterShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

 

afterShutdown() - Method in class org.springframework.integration.ws.AbstractWebServiceInboundGateway

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.aop.PublisherAnnotationBeanPostProcessor

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.config.annotation.MessagingAnnotationPostProcessor

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.config.GlobalChannelInterceptorProcessor

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.config.IntegrationManagementConfigurer

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.dsl.context.IntegrationFlowBeanPostProcessor

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.endpoint.MessageProducerSupport

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.handler.advice.CacheRequestHandlerAdvice

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.jms.JmsMessageDrivenEndpoint

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.monitor.IntegrationMBeanExporter

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector

 

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

 

afterSingletonsInstantiated() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector

 

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

Populate the AggregatingMessageHandler with default options.

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

A short-cut for the aggregate((aggregator) -> aggregator.processor(aggregatorProcessor)).

aggregate(Consumer<AggregatorSpec>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate the AggregatingMessageHandler with provided options from AggregatorSpec.

AggregatedXmlMessageValidationException - Exception in org.springframework.integration.xml

The validation exception which aggregate all the XML validation errors.

AggregatedXmlMessageValidationException(List<Throwable>) - Constructor for exception org.springframework.integration.xml.AggregatedXmlMessageValidationException

 

aggregateHeaders(MessageGroup) - Method in class org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

This default implementation simply returns all headers that have no conflicts among the group.

AggregateMessageDeliveryException - Exception in org.springframework.integration.dispatcher

An Exception that encapsulates an aggregated group of Exceptions for use by dispatchers that may try multiple handler invocations within a single dispatch operation.

AggregateMessageDeliveryException(Message<?>, String, List<? extends Exception>) - Constructor for exception org.springframework.integration.dispatcher.AggregateMessageDeliveryException

 

aggregatePayloads(MessageGroup, Map<String, Object>) - Method in class org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor

 

aggregatePayloads(MessageGroup, Map<String, Object>) - Method in class org.springframework.integration.aggregator.DefaultAggregatingMessageGroupProcessor

 

aggregatePayloads(MessageGroup, Map<String, Object>) - Method in class org.springframework.integration.aggregator.ExpressionEvaluatingMessageGroupProcessor

Evaluate the expression provided on the messages (a collection) in the group, and delegate to the MessagingTemplate to send downstream.

aggregatePayloads(MessageGroup, Map<String, Object>) - Method in class org.springframework.integration.aggregator.MethodInvokingMessageGroupProcessor

 

aggregatePayloads(MessageGroup, Map<String, Object>) - Method in class org.springframework.integration.file.aggregator.FileAggregatingMessageGroupProcessor

 

AggregatingMessageHandler - Class in org.springframework.integration.aggregator

Aggregator specific implementation of AbstractCorrelatingMessageHandler.

AggregatingMessageHandler(MessageGroupProcessor) - Constructor for class org.springframework.integration.aggregator.AggregatingMessageHandler

 

AggregatingMessageHandler(MessageGroupProcessor, MessageGroupStore) - Constructor for class org.springframework.integration.aggregator.AggregatingMessageHandler

 

AggregatingMessageHandler(MessageGroupProcessor, MessageGroupStore, CorrelationStrategy, ReleaseStrategy) - Constructor for class org.springframework.integration.aggregator.AggregatingMessageHandler

 

aggregator - org.springframework.integration.IntegrationPatternType

 

Aggregator - Annotation Type in org.springframework.integration.annotation

Indicates that a method is capable of aggregating messages.

AggregatorAnnotationPostProcessor - Class in org.springframework.integration.config.annotation

Post-processor for the @Aggregator annotation.

AggregatorAnnotationPostProcessor(ConfigurableListableBeanFactory) - Constructor for class org.springframework.integration.config.annotation.AggregatorAnnotationPostProcessor

 

AggregatorFactoryBean - Class in org.springframework.integration.config

FactoryBean to create an AggregatingMessageHandler.

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

 

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

Parser for the aggregator element of the integration namespace.

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

 

AggregatorSpec - Class in org.springframework.integration.dsl

A CorrelationHandlerSpec for an AggregatingMessageHandler.

AggregatorSpec() - Constructor for class org.springframework.integration.dsl.AggregatorSpec

 

ALERT - org.springframework.integration.syslog.RFC5424SyslogParser.Severity

 

ALL - org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway.Option

(-a) Include files beginning with ., including directories . and .. in the results (ls).

ALL - org.springframework.integration.selector.MessageSelectorChain.VotingStrategy

 

allEndpointsRunning(String) - Method in class org.springframework.integration.support.SmartLifecycleRoleController

Return true if all endpoints in the role are running.

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

Allocate a ByteBuffer of the requested length using normal or direct buffers, depending on the usingDirectBuffers field.

allowCredentials(Boolean) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec.CrossOriginSpec

Whether the browser should include any cookies associated with the domain of the request being annotated.

allowedHeaders(String...) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec.CrossOriginSpec

List of request headers that can be used during the actual request.

allowedOrigins() - Method in annotation type org.springframework.integration.http.config.EnableIntegrationGraphController

Specify allowed origin URLs for cross-origin request handling.

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

A Converter that delegates to a Deserializer to convert data in a byte array to an object.

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

Create a AllowListDeserializingConverter with default ObjectInputStream configuration, using the "latest user-defined ClassLoader".

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

Create a AllowListDeserializingConverter for using an ObjectInputStream with the given ClassLoader.

AllowListDeserializingConverter(Deserializer<Object>) - Constructor for class org.springframework.integration.support.converter.AllowListDeserializingConverter

Create a AllowListDeserializingConverter that delegates to the provided Deserializer.

alwaysAccept(F) - Method in class org.springframework.integration.file.filters.AbstractDirectoryAwareFileListFilter

 

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

Set to true to always requeue on transaction rollback with an external TransactionManager.

Amqp - Class in org.springframework.integration.amqp.dsl

Factory class for AMQP components.

AMQP_RAW_MESSAGE - Static variable in class org.springframework.integration.amqp.support.AmqpMessageHeaderErrorMessageStrategy

Header name/retry context variable for the raw received message.

AmqpAckCallback(AmqpMessageSource.AmqpAckInfo) - Constructor for class org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallback

 

AmqpAckCallbackFactory() - Constructor for class org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallbackFactory

 

AmqpAckInfo(Connection, Channel, boolean, GetResponse) - Constructor for class org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckInfo

 

AmqpAsyncOutboundGatewaySpec - Class in org.springframework.integration.amqp.dsl

 

AmqpAsyncOutboundGatewaySpec(AsyncRabbitTemplate) - Constructor for class org.springframework.integration.amqp.dsl.AmqpAsyncOutboundGatewaySpec

 

AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>> - Class in org.springframework.integration.amqp.dsl

The base MessageProducerSpec implementation for a AmqpInboundChannelAdapter.

AmqpBaseInboundChannelAdapterSpec(AmqpInboundChannelAdapter) - Constructor for class org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec

 

AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> - Class in org.springframework.integration.amqp.dsl

A base MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options.

AmqpBaseInboundGatewaySpec(AmqpInboundGateway) - Constructor for class org.springframework.integration.amqp.dsl.AmqpBaseInboundGatewaySpec

 

AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,​E>,​E extends AbstractAmqpOutboundEndpoint> - Class in org.springframework.integration.amqp.dsl

The base MessageHandlerSpec for AbstractAmqpOutboundEndpoints.

AmqpBaseOutboundEndpointSpec() - Constructor for class org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec

 

amqpChannelFactoryBean - Variable in class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

 

AmqpChannelFactoryBean - Class in org.springframework.integration.amqp.config

If point-to-point, we send to the default exchange with the routing key equal to "[beanName]" and we declare that same Queue and register a listener if message-driven or poll explicitly otherwise.

AmqpChannelFactoryBean() - Constructor for class org.springframework.integration.amqp.config.AmqpChannelFactoryBean

 

AmqpChannelFactoryBean(boolean) - Constructor for class org.springframework.integration.amqp.config.AmqpChannelFactoryBean

 

AmqpChannelParser - Class in org.springframework.integration.amqp.config

Parser for the 'channel' and 'publish-subscribe-channel' elements of the Spring Integration AMQP namespace.

AmqpChannelParser() - Constructor for class org.springframework.integration.amqp.config.AmqpChannelParser

 

AmqpHeaderMapper - Interface in org.springframework.integration.amqp.support

A convenience interface that extends RequestReplyHeaderMapper, parameterized with MessageProperties.

AmqpInboundChannelAdapter - Class in org.springframework.integration.amqp.inbound

Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.

AmqpInboundChannelAdapter(AbstractMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter

 

AmqpInboundChannelAdapter(MessageListenerContainer) - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter

Construct an instance using the provided container.

AmqpInboundChannelAdapter.BatchListener - Class in org.springframework.integration.amqp.inbound

 

AmqpInboundChannelAdapter.BatchMode - Enum in org.springframework.integration.amqp.inbound

Defines the payload type when the listener container is configured with consumerBatchEnabled.

AmqpInboundChannelAdapter.Listener - Class in org.springframework.integration.amqp.inbound

 

AmqpInboundChannelAdapterDMLCSpec - Class in org.springframework.integration.amqp.dsl

Spec for an inbound channel adapter with a DirectMessageListenerContainer.

AmqpInboundChannelAdapterDMLCSpec(DirectMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterDMLCSpec

 

AmqpInboundChannelAdapterParser - Class in org.springframework.integration.amqp.config

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

AmqpInboundChannelAdapterSMLCSpec - Class in org.springframework.integration.amqp.dsl

Spec for an inbound channel adapter with a SimpleMessageListenerContainer.

AmqpInboundChannelAdapterSMLCSpec(SimpleMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSMLCSpec

 

AmqpInboundChannelAdapterSpec<S extends AmqpInboundChannelAdapterSpec<S,​C>,​C extends AbstractMessageListenerContainer> - Class in org.springframework.integration.amqp.dsl

A MessageProducerSpec for AmqpInboundChannelAdapters.

AmqpInboundChannelAdapterSpec(AbstractMessageListenerContainerSpec<?, C>) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec

 

AmqpInboundGateway - Class in org.springframework.integration.amqp.inbound

Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.

AmqpInboundGateway(AbstractMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundGateway

 

AmqpInboundGateway(AbstractMessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundGateway

Construct AmqpInboundGateway based on the provided AbstractMessageListenerContainer to receive request messages and AmqpTemplate to send replies.

AmqpInboundGateway(MessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundGateway

Construct AmqpInboundGateway based on the provided MessageListenerContainer to receive request messages and AmqpTemplate to send replies.

AmqpInboundGateway.Listener - Class in org.springframework.integration.amqp.inbound

 

AmqpInboundGatewayDMLCSpec - Class in org.springframework.integration.amqp.dsl

Spec for a gateway with a DirectMessageListenerContainer.

AmqpInboundGatewayDMLCSpec(DirectMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundGatewayDMLCSpec

 

AmqpInboundGatewayDMLCSpec(DirectMessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundGatewayDMLCSpec

 

AmqpInboundGatewayParser - Class in org.springframework.integration.amqp.config

Parser for the AMQP 'inbound-gateway' element.

AmqpInboundGatewaySMLCSpec - Class in org.springframework.integration.amqp.dsl

Spec for a gateway with a SimpleMessageListenerContainer.

AmqpInboundGatewaySMLCSpec(SimpleMessageListenerContainer) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundGatewaySMLCSpec

 

AmqpInboundGatewaySMLCSpec(SimpleMessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundGatewaySMLCSpec

 

AmqpInboundGatewaySpec<S extends AmqpInboundGatewaySpec<S,​C>,​C extends AbstractMessageListenerContainer> - Class in org.springframework.integration.amqp.dsl

An AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway.

AmqpInboundGatewaySpec(AbstractMessageListenerContainerSpec<?, C>) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundGatewaySpec

 

AmqpInboundPolledChannelAdapterSpec - Class in org.springframework.integration.amqp.dsl

Spec for a polled AMQP inbound channel adapter.

AmqpInboundPolledChannelAdapterSpec(ConnectionFactory, String) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundPolledChannelAdapterSpec

 

AmqpInboundPolledChannelAdapterSpec(ConnectionFactory, AmqpMessageSource.AmqpAckCallbackFactory, String) - Constructor for class org.springframework.integration.amqp.dsl.AmqpInboundPolledChannelAdapterSpec

 

AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,​T>,​T extends AbstractAmqpChannel> - Class in org.springframework.integration.amqp.dsl

An AmqpPollableMessageChannelSpec for a message-driven PointToPointSubscribableAmqpChannel.

AmqpMessageChannelSpec(ConnectionFactory) - Constructor for class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

 

amqpMessageConverter(MessageConverter) - Method in class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

 

AmqpMessageHeaderErrorMessageStrategy - Class in org.springframework.integration.amqp.support

An ErrorMessageStrategy extension that adds the raw AMQP message as a header to the ErrorMessage.

AmqpMessageHeaderErrorMessageStrategy() - Constructor for class org.springframework.integration.amqp.support.AmqpMessageHeaderErrorMessageStrategy

 

AmqpMessageSource - Class in org.springframework.integration.amqp.inbound

A pollable MessageSource for RabbitMQ.

AmqpMessageSource(ConnectionFactory, String) - Constructor for class org.springframework.integration.amqp.inbound.AmqpMessageSource

 

AmqpMessageSource(ConnectionFactory, AmqpMessageSource.AmqpAckCallbackFactory, String) - Constructor for class org.springframework.integration.amqp.inbound.AmqpMessageSource

 

AmqpMessageSource.AmqpAckCallback - Class in org.springframework.integration.amqp.inbound

 

AmqpMessageSource.AmqpAckCallbackFactory - Class in org.springframework.integration.amqp.inbound

 

AmqpMessageSource.AmqpAckInfo - Class in org.springframework.integration.amqp.inbound

Information for building an AmqpAckCallback.

AmqpNamespaceHandler - Class in org.springframework.integration.amqp.config

Namespace handler for the AMQP schema.

AmqpNamespaceHandler() - Constructor for class org.springframework.integration.amqp.config.AmqpNamespaceHandler

 

AmqpOutboundChannelAdapterParser - Class in org.springframework.integration.amqp.config

Parser for the AMQP 'outbound-channel-adapter' element.

AmqpOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.amqp.config.AmqpOutboundChannelAdapterParser

 

AmqpOutboundChannelAdapterSpec - Class in org.springframework.integration.amqp.dsl

Spec for an outbound AMQP channel adapter.

AmqpOutboundChannelAdapterSpec(AmqpTemplate) - Constructor for class org.springframework.integration.amqp.dsl.AmqpOutboundChannelAdapterSpec

 

AmqpOutboundEndpoint - Class in org.springframework.integration.amqp.outbound

Adapter that converts and sends Messages to an AMQP Exchange.

AmqpOutboundEndpoint(AmqpTemplate) - Constructor for class org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint

 

AmqpOutboundEndpointSpec<S extends AmqpOutboundEndpointSpec<S>> - Class in org.springframework.integration.amqp.dsl

Base spec for outbound AMQP endpoints.

AmqpOutboundEndpointSpec(AmqpTemplate, boolean) - Constructor for class org.springframework.integration.amqp.dsl.AmqpOutboundEndpointSpec

 

AmqpOutboundGatewayParser - Class in org.springframework.integration.amqp.config

Parser for the AMQP 'outbound-channel-adapter' element.

AmqpOutboundGatewayParser() - Constructor for class org.springframework.integration.amqp.config.AmqpOutboundGatewayParser

 

AmqpOutboundGatewaySpec - Class in org.springframework.integration.amqp.dsl

Spec for an outbound AMQP gateway.

AmqpOutboundGatewaySpec(AmqpTemplate) - Constructor for class org.springframework.integration.amqp.dsl.AmqpOutboundGatewaySpec

 

AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,​T>,​T extends AbstractAmqpChannel> - Class in org.springframework.integration.amqp.dsl

A MessageChannelSpec for a AbstractAmqpChannels.

AmqpPollableMessageChannelSpec(ConnectionFactory) - Constructor for class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec

 

AmqpPublishSubscribeMessageChannelSpec - Class in org.springframework.integration.amqp.dsl

A AmqpMessageChannelSpec for PublishSubscribeAmqpChannels.

AmqpPublishSubscribeMessageChannelSpec(ConnectionFactory) - Constructor for class org.springframework.integration.amqp.dsl.AmqpPublishSubscribeMessageChannelSpec

 

AnnotatedMethodFilter - Class in org.springframework.integration.util

A MethodFilter implementation that enables the following: matching on method name, if available exclusion of void-returning methods if 'requiresReply' is true limiting to annotated methods if at least one is present .

AnnotatedMethodFilter(Class<? extends Annotation>, String, boolean) - Constructor for class org.springframework.integration.util.AnnotatedMethodFilter

 

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

Parser for the <annotation-config> element of the integration namespace.

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

 

AnnotationConstants - Class in org.springframework.integration.annotation

Common value constants for annotation attributes.

AnnotationGatewayProxyFactoryBean - Class in org.springframework.integration.gateway

A GatewayProxyFactoryBean extension for Java configuration.

AnnotationGatewayProxyFactoryBean(Class<?>) - Constructor for class org.springframework.integration.gateway.AnnotationGatewayProxyFactoryBean

 

AnnotationMetadataAdapter - Class in org.springframework.integration.config.annotation

An AnnotationMetadata implementation to expose a metadata by the provided Map of attributes.

AnnotationMetadataAdapter() - Constructor for class org.springframework.integration.config.annotation.AnnotationMetadataAdapter

 

annotationType - Variable in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

ANY - org.springframework.integration.selector.MessageSelectorChain.VotingStrategy

 

ApacheCommonsFileTailingMessageProducer - Class in org.springframework.integration.file.tail

File tailer that delegates to the Apache Commons Tailer.

ApacheCommonsFileTailingMessageProducer() - Constructor for class org.springframework.integration.file.tail.ApacheCommonsFileTailingMessageProducer

 

ApacheMinaFtpEvent - Class in org.springframework.integration.ftp.server

ApplicationEvent generated from Apache Mina ftp events.

ApacheMinaFtpEvent(Object) - Constructor for class org.springframework.integration.ftp.server.ApacheMinaFtpEvent

 

ApacheMinaFtpEvent(Object, Throwable) - Constructor for class org.springframework.integration.ftp.server.ApacheMinaFtpEvent

 

ApacheMinaFtplet - Class in org.springframework.integration.ftp.server

A listener for FTP events emitted by an Apache Mina ftp server.

ApacheMinaFtplet() - Constructor for class org.springframework.integration.ftp.server.ApacheMinaFtplet

 

ApacheMinaSftpEvent - Class in org.springframework.integration.sftp.server

ApplicationEvent generated from Apache Mina sftp events.

ApacheMinaSftpEvent(Object) - Constructor for class org.springframework.integration.sftp.server.ApacheMinaSftpEvent

 

ApacheMinaSftpEvent(Object, Throwable) - Constructor for class org.springframework.integration.sftp.server.ApacheMinaSftpEvent

 

ApacheMinaSftpEventListener - Class in org.springframework.integration.sftp.server

A listener for SFTP events emitted by an Apache Mina sshd/sftp server.

ApacheMinaSftpEventListener() - Constructor for class org.springframework.integration.sftp.server.ApacheMinaSftpEventListener

 

APP_NAME - Static variable in class org.springframework.integration.syslog.SyslogHeaders

 

append(InputStream, String) - Method in class org.springframework.integration.file.remote.session.CachingSessionFactory.CachedSession

 

append(InputStream, String) - Method in interface org.springframework.integration.file.remote.session.Session

Append to a file.

append(InputStream, String) - Method in class org.springframework.integration.ftp.session.FtpSession

 

append(InputStream, String) - Method in class org.springframework.integration.sftp.session.SftpSession

 

append(Message<?>) - Method in interface org.springframework.integration.file.remote.RemoteFileOperations

Send a file to a remote server, based on information in a message, appending.

append(Message<?>) - Method in class org.springframework.integration.file.remote.RemoteFileTemplate

 

append(Message<?>, String) - Method in interface org.springframework.integration.file.remote.RemoteFileOperations

Send a file to a remote server, based on information in a message, appending.

append(Message<?>, String) - Method in class org.springframework.integration.file.remote.RemoteFileTemplate

 

APPEND - org.springframework.integration.file.support.FileExistsMode

Append data to any pre-existing files; close after each append.

APPEND_NO_FLUSH - org.springframework.integration.file.support.FileExistsMode

Append data to any pre-existing files; do not flush/close after appending.

appendNewLine(boolean) - Method in class org.springframework.integration.file.dsl.FileWritingMessageHandlerSpec

If true will append a new-line after each write.

appendNewLine(boolean) - Method in class org.springframework.integration.stream.CharacterStreamWritingMessageHandler

Fluent api for CharacterStreamWritingMessageHandler.setShouldAppendNewLine(boolean).

ApplicationEventListeningMessageProducer - Class in org.springframework.integration.event.inbound

An inbound Channel Adapter that implements GenericApplicationListener and passes Spring ApplicationEvents within messages.

ApplicationEventListeningMessageProducer() - Constructor for class org.springframework.integration.event.inbound.ApplicationEventListeningMessageProducer

 

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

Parser for the <application-event-multicaster> element of the integration namespace.

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

 

ApplicationEventPublishingMessageHandler - Class in org.springframework.integration.event.outbound

A MessageHandler that publishes each Message it receives as a MessagingEvent.

ApplicationEventPublishingMessageHandler() - Constructor for class org.springframework.integration.event.outbound.ApplicationEventPublishingMessageHandler

 

apply(Statement, Description) - Method in class org.springframework.integration.test.support.LongRunningIntegrationTest

 

apply(Statement, FrameworkMethod, Object) - Method in class org.springframework.integration.test.rule.Log4j2LevelAdjuster

 

apply(MessageGroup) - Method in class org.springframework.integration.aggregator.DefaultAggregateHeadersFunction

 

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

 

applyAndBind(String, Iterable<T>, EntityManager) - Static method in class org.springframework.integration.jpa.support.JpaUtils

Creates a where-clause referencing the given entities and appends it to the given query string.

applyReceiveOnlyAdviceChain(Collection<Advice>) - Method in class org.springframework.integration.endpoint.AbstractPollingEndpoint

Add the advice chain to the component that responds to AbstractPollingEndpoint.receiveMessage() calls.

applySequence() - Method in annotation type org.springframework.integration.annotation.Router

Specify whether sequence number and size headers should be added to each Message.

applySequence() - Method in annotation type org.springframework.integration.annotation.Splitter

Set this flag to false to prevent adding sequence related headers in this splitter.

applySequence(boolean) - Method in class org.springframework.integration.dsl.AbstractRouterSpec

 

applySequence(boolean) - Method in class org.springframework.integration.dsl.PublishSubscribeChannelSpec

 

applySequence(boolean) - Method in class org.springframework.integration.dsl.SplitterEndpointSpec

Set the applySequence flag to the specified value.

applySequence(boolean) - Method in class org.springframework.integration.file.dsl.FileSplitterSpec

A boolean flag to indicate if sequenceDetails should be applied for messages based on the lines from file.

applySystemFileSeparator(String) - Static method in class org.springframework.integration.test.util.TestUtils

Update file path by replacing any '/' with the system's file separator.

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

 

ArgumentsStrategy - Interface in org.springframework.integration.redis.outbound

 

ARRAY - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

asFileInfoList(Collection<ChannelSftp.LsEntry>) - Method in class org.springframework.integration.sftp.gateway.SftpOutboundGateway

 

asFileInfoList(Collection<ChannelSftp.LsEntry>) - Method in class org.springframework.integration.sftp.inbound.SftpStreamingMessageSource

 

asFileInfoList(Collection<F>) - Method in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource

 

asFileInfoList(Collection<F>) - Method in class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

 

asFileInfoList(Collection<FTPFile>) - Method in class org.springframework.integration.ftp.gateway.FtpOutboundGateway

 

asFileInfoList(Collection<FTPFile>) - Method in class org.springframework.integration.ftp.inbound.FtpStreamingMessageSource

 

asMap() - Method in class org.springframework.integration.syslog.DefaultMessageConverter

 

assemble(E) - Method in class org.springframework.integration.ws.dsl.BaseWsInboundGatewaySpec

 

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

 

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

 

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

 

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

 

assertHandler() - Method in class org.springframework.integration.dsl.EndpointSpec

 

assertions - Variable in class org.springframework.integration.test.mail.TestMailServer.MailServer

Deprecated.

 

assertReceived(String) - Method in class org.springframework.integration.test.mail.TestMailServer.MailServer

Deprecated.

 

assertReceiver() - Method in class org.springframework.integration.mail.dsl.MailInboundChannelAdapterSpec

 

assertRemoteFileTemplateMutability(String) - Method in class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

 

async() - Method in annotation type org.springframework.integration.annotation.ServiceActivator

Specify whether the service method is async.

async(boolean) - Method in class org.springframework.integration.dsl.BarrierSpec

 

async(boolean) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec

Allow async replies.

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

Set to true to release the sending thread and receive the reply asynchronously.

AsyncAmqpOutboundGateway - Class in org.springframework.integration.amqp.outbound

An outbound gateway where the sending thread is released immediately and the reply is sent on the async template's listener container thread.

AsyncAmqpOutboundGateway(AsyncRabbitTemplate) - Constructor for class org.springframework.integration.amqp.outbound.AsyncAmqpOutboundGateway

 

asyncConvertAndSend(Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertAndSend(Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertAndSend(String, Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertAndSend(String, Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertAndSend(MessageChannel, Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertAndSend(MessageChannel, Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(Object, MessagePostProcessor) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(Object, MessagePostProcessor) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(String, Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(String, Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(String, Object, MessagePostProcessor) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(String, Object, MessagePostProcessor) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(MessageChannel, Object) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(MessageChannel, Object) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncConvertSendAndReceive(MessageChannel, Object, MessagePostProcessor) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncConvertSendAndReceive(MessageChannel, Object, MessagePostProcessor) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncExecutor() - Method in annotation type org.springframework.integration.annotation.MessagingGateway

Provide a reference to an implementation of Executor to use for any of the interface methods that have a Future return type.

asyncExecutor(Executor) - Method in class org.springframework.integration.dsl.GatewayProxySpec

Provide a reference to an implementation of Executor to use for any of the interface methods that have a Future return type.

AsyncMessagingOperations - Interface in org.springframework.integration.core

 

AsyncMessagingTemplate - Class in org.springframework.integration.core

 

AsyncMessagingTemplate() - Constructor for class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncOutboundGateway(AsyncRabbitTemplate) - Static method in class org.springframework.integration.amqp.dsl.Amqp

Create an initial AmqpAsyncOutboundGatewaySpec.

asyncReceive() - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceive() - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncReceive(String) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceive(String) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncReceive(PollableChannel) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceive(PollableChannel) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncReceiveAndConvert() - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceiveAndConvert() - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncReceiveAndConvert(String) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceiveAndConvert(String) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncReceiveAndConvert(PollableChannel) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncReceiveAndConvert(PollableChannel) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSend(String, Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSend(String, Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSend(Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSend(Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSend(MessageChannel, Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSend(MessageChannel, Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSendAndReceive(String, Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSendAndReceive(String, Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSendAndReceive(Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSendAndReceive(Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSendAndReceive(MessageChannel, Message<?>) - Method in interface org.springframework.integration.core.AsyncMessagingOperations

 

asyncSendAndReceive(MessageChannel, Message<?>) - Method in class org.springframework.integration.core.AsyncMessagingTemplate

 

asyncSendMessage(DatagramPacket) - Method in class org.springframework.integration.ip.udp.UnicastReceivingChannelAdapter

 

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

 

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

Set a filename for the attachment.

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

Set an expression that will be evaluated to determine the filename for the attachment.

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

Set a function that will be invoked to determine the filename for the attachment.

AttributePollingChannelAdapterParser - Class in org.springframework.integration.jmx.config

 

AttributePollingChannelAdapterParser() - Constructor for class org.springframework.integration.jmx.config.AttributePollingChannelAdapterParser

 

AttributePollingMessageSource - Class in org.springframework.integration.jmx

A MessageSource implementation that retrieves the current value of a JMX attribute each time AbstractMessageSource.receive() is invoked.

AttributePollingMessageSource() - Constructor for class org.springframework.integration.jmx.AttributePollingMessageSource

 

authPacketArrived(int, MqttProperties) - Method in class org.springframework.integration.mqtt.inbound.Mqttv5PahoMessageDrivenChannelAdapter

 

authPacketArrived(int, MqttProperties) - Method in class org.springframework.integration.mqtt.outbound.Mqttv5PahoMessageHandler

 

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

 

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

 

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

 

AUTO_STARTUP - Static variable in class org.springframework.integration.config.xml.IntegrationNamespaceUtils

 

autoAck(AcknowledgmentCallback) - Static method in class org.springframework.integration.acks.AckUtils

ACCEPT an AcknowledgmentCallback if it's not null, supports auto ack and is not already ack'd.

autoCloseFolder(boolean) - Method in class org.springframework.integration.mail.dsl.ImapIdleChannelAdapterSpec

When configured to false, the folder is not closed automatically after a fetch.

autoCloseFolder(boolean) - Method in class org.springframework.integration.mail.dsl.MailInboundChannelAdapterSpec

When configured to false, the folder is not closed automatically after a fetch.

autoCreateDirectChannel(String, BeanDefinitionRegistry) - Static method in class org.springframework.integration.config.IntegrationConfigUtils

 

autoCreateDirectory(boolean) - Method in class org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec

Specify whether to create the source directory automatically if it does not yet exist upon initialization.

autoCreateDirectory(boolean) - Method in class org.springframework.integration.file.dsl.FileTransferringMessageHandlerSpec

A boolean flag to indicate automatically create the directory or not.

autoCreateDirectory(boolean) - Method in class org.springframework.integration.file.dsl.FileWritingMessageHandlerSpec

Specify whether to create the destination directory automatically if it does not yet exist upon initialization.

autoCreateDirectory(boolean) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec

Determine whether the remote directory should automatically be created when sending files to the remote system.

autoCreateLocalDirectory(boolean) - Method in class org.springframework.integration.file.dsl.RemoteFileInboundChannelAdapterSpec

Configure whether the local directory should be created by the adapter.

autoCreateLocalDirectory(boolean) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec

A boolean flag to identify if local directory should be created automatically.

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

Set to true to automatically declare elements (queues, exchanges, bindings) in the application context during container start().

autoNack(AcknowledgmentCallback) - Static method in class org.springframework.integration.acks.AckUtils

REJECT an AcknowledgmentCallback if it's not null, supports auto ack and is not already ack'd.

autoStartup() - Method in annotation type org.springframework.integration.annotation.Aggregator

The SmartLifecycle autoStartup option.

autoStartup() - Method in annotation type org.springframework.integration.annotation.BridgeFrom

 

autoStartup() - Method in annotation type org.springframework.integration.annotation.BridgeTo

 

autoStartup() - Method in annotation type org.springframework.integration.annotation.Filter

The SmartLifecycle autoStartup option.

autoStartup() - Method in annotation type org.springframework.integration.annotation.InboundChannelAdapter

SmartLifecycle options.

autoStartup() - Method in annotation type org.springframework.integration.annotation.Router

The SmartLifecycle autoStartup option.

autoStartup() - Method in annotation type org.springframework.integration.annotation.ServiceActivator

The SmartLifecycle autoStartup option.

autoStartup() - Method in annotation type org.springframework.integration.annotation.Splitter

The SmartLifecycle autoStartup option.

autoStartup() - Method in annotation type org.springframework.integration.annotation.Transformer

The SmartLifecycle autoStartup option.

autoStartup(boolean) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec

 

autoStartup(boolean) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec

 

autoStartup(boolean) - Method in interface org.springframework.integration.dsl.context.IntegrationFlowContext.IntegrationFlowRegistrationBuilder

The boolean flag to indication if an IntegrationFlow must be started automatically after registration.

autoStartup(boolean) - Method in class org.springframework.integration.dsl.context.StandardIntegrationFlowContext.StandardIntegrationFlowRegistrationBuilder

The boolean flag to indication if an IntegrationFlow must be started automatically after registration.

autoStartup(boolean) - Method in class org.springframework.integration.dsl.EndpointSpec

 

autoStartup(boolean) - Method in class org.springframework.integration.dsl.MessageProducerSpec

 

autoStartup(boolean) - Method in class org.springframework.integration.dsl.MessagingGatewaySpec

An auto-startup flag.

autoStartup(boolean) - Method in class org.springframework.integration.dsl.SourcePollingChannelAdapterSpec

 

autoStartup(boolean) - Method in class org.springframework.integration.file.dsl.TailAdapterSpec

 

autoStartup(boolean) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec

 

availablePermits() - Method in class org.springframework.integration.util.UpperBound

 

AvroHeaders - Class in org.springframework.integration.transformer.support

Pre-defined names and prefixes for Apache Avro related headers.

await() - Method in class org.springframework.integration.test.util.OnlyOnceTrigger

 

B

backlog(int) - Method in class org.springframework.integration.ip.dsl.TcpServerConnectionFactorySpec

 

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

 

backOff(BackOff) - Method in class org.springframework.integration.jms.dsl.JmsDefaultListenerContainerSpec

Specify a BackOff.

barrier - org.springframework.integration.IntegrationPatternType

 

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

Populate a BarrierMessageHandler instance for provided timeout.

barrier(long, Consumer<BarrierSpec>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

Populate a BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec.

BarrierMessageHandler - Class in org.springframework.integration.aggregator

A message handler that suspends the thread until a message with corresponding correlation is passed into the trigger method or the timeout occurs.

BarrierMessageHandler(long) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and default correlation and output strategies.

BarrierMessageHandler(long, long) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeouts and default correlation and output strategies.

BarrierMessageHandler(long, long, CorrelationStrategy) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and correlation strategy, and default output processor.

BarrierMessageHandler(long, long, MessageGroupProcessor) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and output processor, and default correlation strategy.

BarrierMessageHandler(long, long, MessageGroupProcessor, CorrelationStrategy) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and output processor, and default correlation strategy.

BarrierMessageHandler(long, CorrelationStrategy) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and correlation strategy, and default output processor.

BarrierMessageHandler(long, MessageGroupProcessor) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and output processor, and default correlation strategy.

BarrierMessageHandler(long, MessageGroupProcessor, CorrelationStrategy) - Constructor for class org.springframework.integration.aggregator.BarrierMessageHandler

Construct an instance with the provided timeout and output processor, and default correlation strategy.

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

Parser for <int:barrier/>.

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

 

BarrierSpec - Class in org.springframework.integration.dsl

A MessageHandlerSpec for the BarrierMessageHandler.

BarrierSpec(long) - Constructor for class org.springframework.integration.dsl.BarrierSpec

 

BASE_PACKAGE - Static variable in class org.springframework.integration.config.IntegrationConfigUtils

Deprecated.

in favor of IntegrationContextUtils.BASE_PACKAGE.

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

 

BaseHttpInboundEndpoint - Class in org.springframework.integration.http.inbound

The MessagingGatewaySupport extension for HTTP Inbound endpoints with basic properties.

BaseHttpInboundEndpoint(boolean) - Constructor for class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

 

BaseHttpInboundEndpointSpec<S extends BaseHttpInboundEndpointSpec<S,​E>,​E extends HttpRequestHandlingEndpointSupport> - Class in org.springframework.integration.http.dsl

A base MessagingGatewaySpec for the HttpRequestHandlingEndpointSupport implementations.

BaseHttpInboundEndpointSpec(E, String...) - Constructor for class org.springframework.integration.http.dsl.BaseHttpInboundEndpointSpec

 

BaseHttpMessageHandlerSpec<S extends BaseHttpMessageHandlerSpec<S,​E>,​E extends AbstractHttpRequestExecutingMessageHandler> - Class in org.springframework.integration.http.dsl

The base MessageHandlerSpec for AbstractHttpRequestExecutingMessageHandlers.

BaseHttpMessageHandlerSpec(E) - Constructor for class org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec

 

BaseIntegrationFlowDefinition<B extends BaseIntegrationFlowDefinition<B>> - Class in org.springframework.integration.dsl

The Builder pattern implementation for the EIP-method chain.

BaseIntegrationFlowDefinition() - Constructor for class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

 

BaseIntegrationFlowDefinition.ReplyProducerCleaner - Class in org.springframework.integration.dsl

 

basePackageClasses() - Method in annotation type org.springframework.integration.annotation.IntegrationComponentScan

Type-safe alternative to IntegrationComponentScan.basePackages() for specifying the packages to scan for annotated components.

basePackages() - Method in annotation type org.springframework.integration.annotation.IntegrationComponentScan

Base packages to scan for annotated components.

BaseWsInboundGatewaySpec<S extends BaseWsInboundGatewaySpec<S,​E>,​E extends AbstractWebServiceInboundGateway> - Class in org.springframework.integration.ws.dsl

Base MessagingGatewaySpec for web services.

BaseWsInboundGatewaySpec() - Constructor for class org.springframework.integration.ws.dsl.BaseWsInboundGatewaySpec

Construct an instance.

BaseWsOutboundGatewaySpec<S extends BaseWsOutboundGatewaySpec<S,​E>,​E extends AbstractWebServiceOutboundGateway> - Class in org.springframework.integration.ws.dsl

The base MessageHandlerSpec for AbstractWebServiceOutboundGateways.

BaseWsOutboundGatewaySpec() - Constructor for class org.springframework.integration.ws.dsl.BaseWsOutboundGatewaySpec

 

BasicMessageGroupStore - Interface in org.springframework.integration.store

Defines a minimal message group store with basic capabilities.

batch - org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.ListenerMode

Each Message will be converted from the ConsumerRecords returned by a poll.

batchingStrategy(BatchingStrategy) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseInboundGatewaySpec

Set a batching strategy to use when de-batching messages.

BatchListener() - Constructor for class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.BatchListener

 

batchMessageConverter(BatchMessageConverter) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec

Set the message converter to use with a batch-based consumer.

batchMode(AmqpInboundChannelAdapter.BatchMode) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSMLCSpec

Set the AmqpInboundChannelAdapter.BatchMode to use when the container is configured to support batching consumed records.

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

Configure the batch size.

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

The batch size to use.

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

Set the bcc: addresses.

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

 

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

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

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

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

BEAN_NAME - Static variable in class org.springframework.integration.scripting.config.ScriptExecutingProcessorFactory

 

beanAnnotationAware() - Method in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

beanAnnotationAware() - Method in class org.springframework.integration.config.annotation.AggregatorAnnotationPostProcessor

 

BeanDefinitionRegisteringParser - Interface in org.springframework.integration.config.xml

Simple strategy interface for parsers that are responsible for parsing an element, creating a bean definition, and then registering the bean.

beanFactory - Variable in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

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

DestinationResolver implementation based on a Spring BeanFactory.

BeanFactoryChannelResolver() - Constructor for class org.springframework.integration.support.channel.BeanFactoryChannelResolver

Create a new instance of the BeanFactoryChannelResolver class.

BeanFactoryChannelResolver(BeanFactory) - Constructor for class org.springframework.integration.support.channel.BeanFactoryChannelResolver

Create a new instance of the BeanFactoryChannelResolver class.

BeanFactoryTypeConverter - Class in org.springframework.integration.util

 

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

 

BeanFactoryTypeConverter(ConversionService) - Constructor for class org.springframework.integration.util.BeanFactoryTypeConverter

 

beanName(String) - Method in class org.springframework.integration.dsl.GatewayProxySpec

Specify a bean name for the target GatewayProxyFactoryBean.

BeanNameMessageProcessor<T> - Class in org.springframework.integration.handler

An "artificial" MessageProcessor for lazy-load of target bean by its name.

BeanNameMessageProcessor(String, String) - Constructor for class org.springframework.integration.handler.BeanNameMessageProcessor

 

BeanPropertyParameterSource - Class in org.springframework.integration.jpa.support.parametersource

 

BeanPropertyParameterSource(Object) - Constructor for class org.springframework.integration.jpa.support.parametersource.BeanPropertyParameterSource

Create a new BeanPropertySqlParameterSource for the given bean.

BeanPropertyParameterSourceFactory - Class in org.springframework.integration.jpa.support.parametersource

 

BeanPropertyParameterSourceFactory() - Constructor for class org.springframework.integration.jpa.support.parametersource.BeanPropertyParameterSourceFactory

 

BeanPropertySqlParameterSourceFactory - Class in org.springframework.integration.jdbc

A default implementation of SqlParameterSourceFactory which creates an SqlParameterSource to reference bean properties in its input.

BeanPropertySqlParameterSourceFactory() - Constructor for class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory

 

beforeCommit(String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

beforeCommit(String, String) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

beforeCommit(String, MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

beforeCommit(MessageChannel) - Method in class org.springframework.integration.transaction.TransactionSynchronizationFactoryBean

 

beforeEach(ExtensionContext) - Method in class org.springframework.integration.test.condition.LogLevelsCondition

 

beforeHandle(Message<?>, MessageChannel, MessageHandler) - Method in class org.springframework.integration.channel.interceptor.ThreadStatePropagationChannelInterceptor

 

beforeReceive(Object) - Method in interface org.springframework.integration.aop.MessageSourceMutator

 

beforeReceive(Object) - Method in interface org.springframework.integration.aop.ReceiveMessageAdvice

Subclasses can decide whether to Joinpoint.proceed() or not.

beforeReceive(MessageSource<?>) - Method in interface org.springframework.integration.aop.MessageSourceMutator

Subclasses can decide whether to proceed with this poll.

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

 

beforeReceive(MessageSource<?>) - Method in interface org.springframework.integration.file.remote.aop.RotationPolicy

Invoked before the message source receive() method.

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

 

beforeShutdown() - Method in class org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter

 

beforeShutdown() - Method in interface org.springframework.integration.context.OrderlyShutdownCapable

Called before shutdown begins.

beforeShutdown() - Method in class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

 

beforeShutdown() - Method in class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory

 

beforeShutdown() - Method in class org.springframework.integration.ip.tcp.TcpInboundGateway

 

beforeShutdown() - Method in class org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter

 

beforeShutdown() - Method in class org.springframework.integration.jms.JmsInboundGateway

 

beforeShutdown() - Method in class org.springframework.integration.jms.JmsMessageDrivenEndpoint

 

beforeShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaInboundGateway

 

beforeShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

 

beforeShutdown() - Method in class org.springframework.integration.ws.AbstractWebServiceInboundGateway

 

BIGINT - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

BINARY - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

BinaryToMessageConverter - Class in org.springframework.integration.mongodb.support

 

BinaryToMessageConverter() - Constructor for class org.springframework.integration.mongodb.support.BinaryToMessageConverter

 

bindFunction(BiFunction<DatabaseClient.GenericExecuteSpec, ?, DatabaseClient.GenericExecuteSpec>) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageSourceSpec

Set a BiFunction which is used to bind parameters into the update query.

bindPort(int) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec

Configure a port for TCP protocol binding via ZMQ.Socket.bind(String).

bindSourceMessage(boolean) - Method in class org.springframework.integration.amqp.dsl.AmqpBaseInboundGatewaySpec

Set to true to bind the source message in the headers.

BIT - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

BLOB - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

BLOCKING_QUEUE - org.springframework.integration.store.SimpleMessageGroupFactory.GroupType

 

BODY - Static variable in class org.springframework.integration.test.mail.TestMailServer.MailServer.MailHandler

Deprecated.

 

bodyExtractor(BodyExtractor<?, ? super ClientHttpResponse>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec

Specify a BodyExtractor as an alternative to the expectedResponseType to allow to get low-level access to the received ClientHttpResponse.

BOOLEAN - org.springframework.integration.jdbc.config.JdbcTypesEnum

 

BOOLEAN - Static variable in class org.springframework.integration.xml.xpath.XPathUtils

 

BOOLEAN_RESULT - org.springframework.integration.xml.xpath.XPathEvaluationType

 

BooleanTestXPathMessageSelector - Class in org.springframework.integration.xml.selector

Boolean XPath testing MessageSelector.

BooleanTestXPathMessageSelector(String) - Constructor for class org.springframework.integration.xml.selector.BooleanTestXPathMessageSelector

Create a boolean testing XPath MessageSelector with no namespace support.

BooleanTestXPathMessageSelector(String, String, String) - Constructor for class org.springframework.integration.xml.selector.BooleanTestXPathMessageSelector

Create a boolean testing XPath MessageSelector supporting a single namespace.

BooleanTestXPathMessageSelector(String, Map<String, String>) - Constructor for class org.springframework.integration.xml.selector.BooleanTestXPathMessageSelector

Create a boolean testing XPath MessageSelector supporting multiple namespaces.

BooleanTestXPathMessageSelector(XPathExpression) - Constructor for class org.springframework.integration.xml.selector.BooleanTestXPathMessageSelector

Create a boolean testing XPath MessageSelector using the provided XPathExpression.

bounded() - Method in interface org.springframework.integration.zookeeper.lock.ZookeeperLockRegistry.KeyToPathStrategy

 

BoundRabbitChannelAdvice - Class in org.springframework.integration.amqp.support

An advice that causes all downstream RabbitOperations operations to be executed on the same channel, as long as there are no thread handoffs, since the channel is bound to the thread.

BoundRabbitChannelAdvice(RabbitOperations) - Constructor for class org.springframework.integration.amqp.support.BoundRabbitChannelAdvice

Construct an instance that doesn't wait for confirms.

BoundRabbitChannelAdvice(RabbitOperations, Duration) - Constructor for class org.springframework.integration.amqp.support.BoundRabbitChannelAdvice

Construct an instance that waits for publisher confirms (if configured and waitForConfirmsTimeout is not null).

bridge - org.springframework.integration.IntegrationPatternType

 

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

Populate a BridgeHandler to the current integration flow position.

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

Populate a BridgeHandler to the current integration flow position.

BridgeFrom - Annotation Type in org.springframework.integration.annotation

Messaging Annotation to mark a Bean method for a MessageChannel to produce a BridgeHandler and Consumer Endpoint.

BridgeFromAnnotationPostProcessor - Class in org.springframework.integration.config.annotation

Post-processor for the @BridgeFrom annotation.

BridgeFromAnnotationPostProcessor(ConfigurableListableBeanFactory) - Constructor for class org.springframework.integration.config.annotation.BridgeFromAnnotationPostProcessor

 

BridgeHandler - Class in org.springframework.integration.handler

A simple MessageHandler implementation that passes the request Message directly to the output channel without modifying it.

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

 

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

Parser for the <bridge> element.

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

 

BridgeTo - Annotation Type in org.springframework.integration.annotation

Messaging Annotation to mark a Bean method for a MessageChannel to produce a BridgeHandler and Consumer Endpoint.

BridgeToAnnotationPostProcessor - Class in org.springframework.integration.config.annotation

Post-processor for the @BridgeTo annotation.

BridgeToAnnotationPostProcessor(ConfigurableListableBeanFactory) - Constructor for class org.springframework.integration.config.annotation.BridgeToAnnotationPostProcessor

 

BroadcastCapableChannel - Interface in org.springframework.integration.channel

A SubscribableChannel variant for implementations with broadcasting capabilities.

BroadcastingDispatcher - Class in org.springframework.integration.dispatcher

A broadcasting dispatcher implementation.

BroadcastingDispatcher() - Constructor for class org.springframework.integration.dispatcher.BroadcastingDispatcher

 

BroadcastingDispatcher(boolean) - Constructor for class org.springframework.integration.dispatcher.BroadcastingDispatcher

 

BroadcastingDispatcher(Executor) - Constructor for class org.springframework.integration.dispatcher.BroadcastingDispatcher

 

BroadcastingDispatcher(Executor, boolean) - Constructor for class org.springframework.integration.dispatcher.BroadcastingDispatcher

 

BroadcastPublishSubscribeSpec - Class in org.springframework.integration.dsl

An IntegrationComponentSpec for configuring sub-flow subscribers on the provided BroadcastCapableChannel.

BroadcastPublishSubscribeSpec(BroadcastCapableChannel) - Constructor for class org.springframework.integration.dsl.BroadcastPublishSubscribeSpec

 

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

Set the buffer size to use while writing to files; default 8192.

build() - Method in interface org.springframework.integration.expression.ExpressionEvalMap.ExpressionEvalMapFinalBuilder

 

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

 

build() - Method in interface org.springframework.integration.support.management.metrics.MetricsCaptor.CounterBuilder

Build the counter.

build() - Method in interface org.springframework.integration.support.management.metrics.MetricsCaptor.GaugeBuilder

Build the gauge.

build() - Method in interface org.springframework.integration.support.management.metrics.MetricsCaptor.TimerBuilder

Build the timer.

build() - Method in class org.springframework.integration.support.management.micrometer.MicrometerMetricsCaptor.MicroCounterBuilder

 

build() - Method in class org.springframework.integration.support.management.micrometer.MicrometerMetricsCaptor.MicroGaugeBuilder

 

build() - Method in class org.springframework.integration.support.management.micrometer.MicrometerMetricsCaptor.MicroTimerBuilder

 

build() - Method in class org.springframework.integration.support.MessageBuilder

 

build() - Method in class org.springframework.integration.support.MutableMessageBuilder

 

build() - Method in class org.springframework.integration.transaction.TransactionInterceptorBuilder

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.amqp.config.AmqpChannelParser

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractChannelParser

Subclasses must implement this method to create the bean definition.

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.config.xml.PointToPointChannelParser

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.config.xml.PublishSubscribeChannelParser

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.jms.config.JmsChannelParser

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.kafka.config.xml.KafkaChannelParser

 

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisChannelParser

 

buildErrorMessage(Throwable, AttributeAccessor) - Method in class org.springframework.integration.amqp.support.AmqpMessageHeaderErrorMessageStrategy

 

buildErrorMessage(Throwable, AttributeAccessor) - Method in class org.springframework.integration.kafka.support.RawRecordHeaderErrorMessageStrategy

 

buildErrorMessage(Throwable, AttributeAccessor) - Method in class org.springframework.integration.support.DefaultErrorMessageStrategy

 

buildErrorMessage(Throwable, AttributeAccessor) - Method in interface org.springframework.integration.support.ErrorMessageStrategy

Build the error message.

buildErrorMessage(Message<?>, Exception) - Method in class org.springframework.integration.endpoint.MessageProducerSupport

Build an error message for the exception and message using the configured ErrorMessageStrategy.

buildErrorMessage(Message<?>, Throwable) - Method in class org.springframework.integration.gateway.MessagingGatewaySupport

Build an error message for the message and throwable using the configured ErrorMessageStrategy.

buildFlow() - Method in class org.springframework.integration.dsl.IntegrationFlowAdapter

 

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

The default key is the AbstractPersistentAcceptOnceFileListFilter.prefix plus the full filename.

buildLambdaMessageProcessorForBeanMethod(Method, Object) - Method in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

buildMessage(Object) - Method in class org.springframework.integration.endpoint.AbstractMessageSource

 

buildMessage(MutableMessageHeaders, Object, JsonNode, DeserializationContext) - Method in class org.springframework.integration.support.json.AdviceMessageJacksonDeserializer

 

buildMessage(MutableMessageHeaders, Object, JsonNode, DeserializationContext) - Method in class org.springframework.integration.support.json.ErrorMessageJacksonDeserializer

 

buildMessage(MutableMessageHeaders, Object, JsonNode, DeserializationContext) - Method in class org.springframework.integration.support.json.GenericMessageJacksonDeserializer

 

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

 

buildMessage(MutableMessageHeaders, Object, JsonNode, DeserializationContext) - Method in class org.springframework.integration.support.json.MutableMessageJacksonDeserializer

 

buildNewConnection() - Method in class org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory

 

buildNewConnection() - Method in class org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory

 

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

 

buildReply(MessageConverter, Message) - Method in class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint

 

buildResolvableType(Class<?>, Class<?>, Class<?>) - Static method in class org.springframework.integration.mapping.support.JsonHeaders

Build a ResolvableType for provided class components.

buildResolvableType(ClassLoader, Object, Object, Object) - Static method in class org.springframework.integration.mapping.support.JsonHeaders

Build a ResolvableType for provided class components.

buildResult(Object, Message<?>, Message<?>) - Method in class org.springframework.integration.aggregator.BarrierMessageHandler

Override to change the default mechanism by which the inbound and release messages are returned as a result.

buildReturnedMessage(Message, int, String, String, String, MessageConverter) - Method in class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint

Deprecated.

since 5.4 in favor of AbstractAmqpOutboundEndpoint.buildReturnedMessage(ReturnedMessage, MessageConverter)

buildReturnedMessage(ReturnedMessage, MessageConverter) - Method in class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint

 

buildSendTimer(boolean, String) - Method in class org.springframework.integration.gateway.MessagingGatewaySupport

 

buildSendTimer(boolean, String) - Method in class org.springframework.integration.handler.MessageHandlerSupport

 

ByteArrayCrLfSerializer - Class in org.springframework.integration.ip.tcp.serializer

Reads data in an InputStream to a byte[]; data must be terminated by \r\n (not included in resulting byte[]).

ByteArrayCrLfSerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayCrLfSerializer

 

ByteArrayElasticRawDeserializer - Class in org.springframework.integration.ip.tcp.serializer

A deserializer that uses a ByteArrayOutputStream instead of a fixed buffer, allowing the buffer to grow as needed.

ByteArrayElasticRawDeserializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayElasticRawDeserializer

Construct an instance that uses ByteArrayOutputStreams with an initial buffer size of 32.

ByteArrayElasticRawDeserializer(int) - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayElasticRawDeserializer

Construct an instance that uses ByteArrayOutputStreams with the provided initial buffer size.

ByteArrayLengthHeaderSerializer - Class in org.springframework.integration.ip.tcp.serializer

Reads data in an InputStream to a byte[]; data must be preceded by a binary length (network byte order, not included in resulting byte[]).

ByteArrayLengthHeaderSerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayLengthHeaderSerializer

Construct the serializer using ByteArrayLengthHeaderSerializer.HEADER_SIZE_INT.

ByteArrayLengthHeaderSerializer(int) - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayLengthHeaderSerializer

Construct the serializer using the supplied header size.

ByteArrayLfSerializer - Class in org.springframework.integration.ip.tcp.serializer

 

ByteArrayLfSerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayLfSerializer

 

ByteArrayRawSerializer - Class in org.springframework.integration.ip.tcp.serializer

A byte array (de)serializer that does nothing with the payload; sends it raw.

ByteArrayRawSerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayRawSerializer

 

ByteArrayRawSerializer(boolean) - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayRawSerializer

Treat socket timeouts as a normal EOF and emit the (possibly partial) message.

ByteArraySingleTerminatorSerializer - Class in org.springframework.integration.ip.tcp.serializer

Reads data in an InputStream to a byte[]; data must be terminated by a single byte (not included in resulting byte[]).

ByteArraySingleTerminatorSerializer(byte) - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArraySingleTerminatorSerializer

 

ByteArrayStxEtxSerializer - Class in org.springframework.integration.ip.tcp.serializer

Reads data in an InputStream to a byte[]; data must be prefixed by <stx> and terminated by <etx> (not included in resulting byte[]).

ByteArrayStxEtxSerializer() - Constructor for class org.springframework.integration.ip.tcp.serializer.ByteArrayStxEtxSerializer

 

BYTES - org.springframework.integration.json.ObjectToJsonTransformer.ResultType

 

BytesMessageMapper - Interface in org.springframework.integration.mapping

An OutboundMessageMapper and InboundMessageMapper that maps to/from byte[].

bytesToString(byte[], String) - Static method in class org.springframework.integration.support.utils.IntegrationUtils

Utility method for null-safe conversion from byte[] to String.

ByteStreamReadingMessageSource - Class in org.springframework.integration.stream

A pollable source for receiving bytes from an InputStream.

ByteStreamReadingMessageSource(InputStream) - Constructor for class org.springframework.integration.stream.ByteStreamReadingMessageSource

 

ByteStreamReadingMessageSource(InputStream, int) - Constructor for class org.springframework.integration.stream.ByteStreamReadingMessageSource

 

ByteStreamWritingMessageHandler - Class in org.springframework.integration.stream

A MessageHandler that writes a byte array to an OutputStream.

ByteStreamWritingMessageHandler(OutputStream) - Constructor for class org.springframework.integration.stream.ByteStreamWritingMessageHandler

 

ByteStreamWritingMessageHandler(OutputStream, int) - Constructor for class org.springframework.integration.stream.ByteStreamWritingMessageHandler

 

C

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.

CacheListeningMessageProducer - Class in org.springframework.integration.gemfire.inbound

An inbound endpoint that listens to a GemFire region for events and then publishes Messages to a channel.

CacheListeningMessageProducer(Region<?, ?>) - Constructor for class org.springframework.integration.gemfire.inbound.CacheListeningMessageProducer

 

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.

CacheWritingMessageHandler - Class in org.springframework.integration.gemfire.outbound

A MessageHandler implementation that writes to a GemFire Region.

CacheWritingMessageHandler(Region) - Constructor for class org.springframework.integration.gemfire.outbound.CacheWritingMessageHandler

 

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.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.

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

 

categories() - Method in annotation type 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.

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

 

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

Set the cc: addresses.

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

 

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

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

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

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

chain - 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() - Method in annotation type org.springframework.integration.annotation.InboundChannelAdapter

 

channel() - Method in annotation type org.springframework.integration.annotation.Publisher

 

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.jms.dsl.Jms

The factory to produce a JmsMessageChannelSpec.

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

Interface to encapsulate ConfigAttributes for secured channel send and receive operations.

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

Secured object for ChannelSecurityInterceptor.

ChannelInvocation(MethodInvocation) - Constructor for class org.springframework.integration.security.channel.ChannelInvocation

 

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() - Method in annotation type 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 - Variable in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

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

An AOP interceptor that enforces authorization for MessageChannel send and/or receive calls.

ChannelSecurityInterceptor() - Constructor for class org.springframework.integration.security.channel.ChannelSecurityInterceptor

 

ChannelSecurityInterceptor(ChannelSecurityMetadataSource) - Constructor for class org.springframework.integration.security.channel.ChannelSecurityInterceptor

 

ChannelSecurityInterceptorBeanPostProcessor - Class in org.springframework.integration.security.config

A BeanPostProcessor that proxies MessageChannels to apply a ChannelSecurityInterceptor.

ChannelSecurityInterceptorBeanPostProcessor(Map<String, Set<Pattern>>) - Constructor for class org.springframework.integration.security.config.ChannelSecurityInterceptorBeanPostProcessor

 

ChannelSecurityInterceptorBeanPostProcessor(Map<String, Set<Pattern>>, Map<String, Map<Pattern, ChannelAccessPolicy>>) - Constructor for class org.springframework.integration.security.config.ChannelSecurityInterceptorBeanPostProcessor

 

ChannelSecurityMetadataSource - Class in org.springframework.integration.security.channel

The SecurityMetadataSource implementation for secured MessageChannels.

ChannelSecurityMetadataSource() - Constructor for class org.springframework.integration.security.channel.ChannelSecurityMetadataSource

 

ChannelSecurityMetadataSource(Map<Pattern, ChannelAccessPolicy>) - Constructor for class org.springframework.integration.security.channel.ChannelSecurityMetadataSource

 

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 - 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.annotation.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 - org.springframework.integration.IntegrationPatternType

 

claim_check_out - 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() - Method in annotation type 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.

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

 

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_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

 

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 - 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 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.

Codec - Interface in org.springframework.integration.codec

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

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

 

CodecMessageConverter - Class in org.springframework.integration.codec

A MessageConverter that delegates to a Codec to convert.

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

 

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

Configure a collection to subscribe for change events.

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

The header for MongoDb collection name.

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

A HandlerMethodArgumentResolver implementation for Collection, Iterator or array MethodParameter.

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

 

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

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

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

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

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

 

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

Configure a collection name to query against.

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

Identify the name of the MongoDb collection to use.

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

Configure a collection name to store data.

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

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

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

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

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

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

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

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

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

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

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

Configure a Function for evaluation a collection against request message.

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

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

COMMAND - 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() - Method in annotation type 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

 

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 CompoundTrigger.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(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

 

configure(RmiProxyFactoryBean) - Method in interface org.springframework.integration.rmi.RmiOutboundGateway.RmiProxyFactoryBeanConfigurer

Deprecated.

Perform additional configuration of the factory bean before the RequestReplyExchanger is created.

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<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.annotation.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.

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, 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.inbound.MqttPahoMessageDrivenChannelAdapter

 

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

 

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.

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

 

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 in org.springframework.integration.mqtt.core

Action to take regarding subscrptions when consumer stops.

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

Set the implementation of ConsumerTagStrategy to generate consumer tags.

consumerTaskExecutor(AsyncListenableTaskExecutor) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec

Set the executor for threads that poll the consumer.

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, String) - Static method in class org.springframework.integration.jms.dsl.Jms

The factory to produce a JmsListenerContainerSpec.

container(ConnectionFactory, Destination) - 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 - org.springframework.integration.IntegrationPatternType

 

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

 

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

 

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

 

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

 

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

 

ContentEnricher - Class in org.springframework.integration.transformer

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

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

 

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

Set the content type.

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

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

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

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

Context - Interface in org.springframework.integration.leader

Interface that defines the context for candidate leadership.

ContinuousQueryMessageProducer - Class in org.springframework.integration.gemfire.inbound

Responds to a Gemfire continuous query (set using the #query field) that is constantly evaluated against a cache Region.

ContinuousQueryMessageProducer(ContinuousQueryListenerContainer, String) - Constructor for class org.springframework.integration.gemfire.inbound.ContinuousQueryMessageProducer

 

control_bus - 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

 

conversionService - Variable in class org.springframework.integration.config.annotation.AbstractMethodAnnotationPostProcessor

 

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

 

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

 

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

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

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

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

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

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

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

 

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

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

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

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

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

 

ConvertingBytesMessageMapper - Class in org.springframework.integration.mapping

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

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

 

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 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.

CorrelatingMessageBarrier - Class in org.springframework.integration.aggregator

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

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

 

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

 

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

 

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

 

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

Configure the handler with an ExpressionEvaluatingCorrelationStrategy for the given expression.

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

A MessageHandlerSpec for an AbstractCorrelatingMessageHandler.

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

 

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

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.

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

Add a IntegrationMessageHeaderAccessor.CORRELATION_ID header.

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

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

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

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

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

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

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

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

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

 

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

 

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

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

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

 

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

 

CorrelationStrategy - Interface in org.springframework.integration.aggregator

Strategy for determining how messages can be correlated.

CorrelationStrategy - Annotation Type 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

 

CqEventType - Enum in org.springframework.integration.gemfire.inbound

Enumeration of GemFire Continuous Query Event Types.

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

 

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

 

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

 

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.SimpleWsInboundGatewaySpec

 

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 - 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 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

 

CREATED - org.springframework.integration.gemfire.inbound.CqEventType

 

CREATED - org.springframework.integration.gemfire.inbound.EventType

 

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.annotation.AbstractMethodAnnotationPostProcessor

 

createEndpoint(MessageHandler, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.BridgeToAnnotationPostProcessor

 

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.annotation.AbstractMethodAnnotationPostProcessor

Subclasses must implement this method to create the MessageHandler.

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.AggregatorAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.BridgeFromAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.BridgeToAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.FilterAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.InboundChannelAdapterAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.RouterAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.ServiceActivatorAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.SplitterAnnotationPostProcessor

 

createHandler(Object, Method, List<Annotation>) - Method in class org.springframework.integration.config.annotation.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.sftp.session.JschProxyFactoryBean

 

createInstance() - Method in class org.springframework.integration.syslog.config.SyslogReceivingChannelAdapterFactoryBean

 

createInstance() - Method in class org.springframework.integration.xmpp.config.XmppConnectionFactoryBean

 

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(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.

createSocket(String, int) - Method in class org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory

Create a new Socket.

createSource(Object) - Method in class org.springframework.integration.xml.source.DomSourceFactory

 

createSource(Object) - Method in interface org.springframework.integration.xml.source.SourceFactory

Create appropriate Source instance for payload

createSource(Object) - Method in class org.springframework.integration.xml.source.StringSourceFactory

 

createStandardEvaluationContext() - Static method in class org.springframework.integration.expression.ExpressionUtils

Used to create a context with no BeanFactory, usually in tests.

createStandardEvaluationContext(BeanFactory) - Static method in class org.springframework.integration.expression.ExpressionUtils

Obtains the context from the beanFactory if not null; emits a warning if the beanFactory is null.

createTargetPropertyName(String, boolean) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper

Alter the specified propertyName if necessary.

createTaskScheduler(int) - Static method in class org.springframework.integration.test.util.TestUtils

A factory for the ThreadPoolTaskScheduler instances based on the provided poolSize.

createTestApplicationContext() - Static method in class org.springframework.integration.test.util.TestUtils

Create a TestUtils.TestApplicationContext instance supplied with the basic Spring Integration infrastructure.

createWriter(File, boolean) - Method in class org.springframework.integration.file.FileWritingMessageHandler

Create a buffered writer for the file, for String payloads.

credentials(String, String) - Method in class org.springframework.integration.mail.dsl.MailSendingMessageHandlerSpec

Set the credentials.

criteria(String) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a SpEL expression to evaluate a Criteria for query to execute.

criteria(Function<Message<P>, Criteria>) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a Function to evaluate a Criteria for query to execute.

criteria(Expression) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec

Set a SpEL expression to evaluate a Criteria for query to execute.

CRITICAL - 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() - Method in annotation type 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() - Method in annotation type 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.