Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
P
- pack(Collection<ZipEntrySource>, int) - Static method in class org.springframework.integration.zip.transformer.SpringZipUtils
- pack(Collection<ZipEntrySource>, File, int) - Static method in class org.springframework.integration.zip.transformer.SpringZipUtils
- PACKET_ADDRESS - Static variable in class org.springframework.integration.ip.IpHeaders
-
The remote address for a UDP packet.
- parameter(Object) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
-
Add a value for indexed query parameter.
- parameter(String, Object) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
-
Add a value for named parameter in the query.
- parameter(String, String) - Method in class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
-
Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.
- parameter(String, Function<Message<?>, ?>) - Method in class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
-
Add a named bindable parameter with a function to evaluate its value against a request message.
- parameter(String, Expression) - Method in class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
-
Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.
- parameter(JpaParameter) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
- parameterExpression(String) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
-
Add a SpEL expression for indexed parameter in the query.
- parameterExpression(String, String) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
-
Add a SpEL expression for named parameter in the query.
- parameterExpressions(Map<String, Expression>) - Method in class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
-
Set a map for named parameters and expressions for their values against a request message.
- parameterSource(ParameterSource) - Method in class org.springframework.integration.jpa.dsl.JpaInboundChannelAdapterSpec
-
Specify a
ParameterSource
that would be used to provide additional parameters. - ParameterSource - Interface in org.springframework.integration.jpa.support.parametersource
- parameterSourceFactory(ParameterSourceFactory) - Method in class org.springframework.integration.jpa.dsl.JpaBaseOutboundEndpointSpec
-
Specify a
ParameterSourceFactory
to populate query parameters at runtime against request message. - ParameterSourceFactory - Interface in org.springframework.integration.jpa.support.parametersource
- parameterType() - Method in record class org.springframework.integration.http.management.ControlBusController.CommandArgument
-
Returns the value of the
parameterType
record component. - parameterTypes() - Method in record class org.springframework.integration.http.management.ControlBusController.ControlBusCommand
-
Returns the value of the
parameterTypes
record component. - params(String...) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec.RequestMappingSpec
-
The parameters of the mapped request, narrowing the primary mapping.
- parse(String, int, boolean) - Method in class org.springframework.integration.syslog.RFC5424SyslogParser
- parse(Properties) - Static method in class org.springframework.integration.context.IntegrationProperties
-
Parse a provided
Properties
and build anIntegrationProperties
instance. - parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractIntegrationNamespaceHandler
- parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AnnotationConfigParser
- parse(Element, ParserContext) - Method in interface org.springframework.integration.config.xml.BeanDefinitionRegisteringParser
- parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.GatewayParser
- parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.MessageHistoryParser
- parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.SpelPropertyAccessorsParser
- parse(Element, ParserContext) - Method in class org.springframework.integration.config.xml.WireTapParser
- parse(Element, ParserContext) - Method in class org.springframework.integration.http.config.IntegrationGraphControllerParser
- parseAcknowledgeMode(String) - Static method in class org.springframework.integration.jms.util.JmsAdapterUtils
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.amqp.config.AmqpOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.cassandra.config.xml.CassandraOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser
-
Override this method to return the BeanDefinition for the MessageConsumer.
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.config.xml.DefaultOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.config.xml.LoggingChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.event.config.EventOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.file.config.FileOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.file.config.RemoteFileOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.hazelcast.config.xml.HazelcastOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.http.config.HttpOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.ip.config.TcpOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.ip.config.UdpOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcMessageHandlerParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcMessageHandlerParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jms.config.JmsOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jmx.config.NotificationPublishingChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jmx.config.OperationInvokingChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jpa.config.xml.JpaOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.kafka.config.xml.KafkaOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.mail.config.MailOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.mongodb.config.MongoDbOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.mqtt.config.xml.MqttOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisQueueOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisStoreOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.stomp.config.StompOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.stream.config.ConsoleOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.websocket.config.WebSocketOutboundMessageHandlerParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.xmpp.config.AbstractXmppOutboundChannelAdapterParser
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.xmpp.config.ChatMessageOutboundChannelAdapterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.amqp.config.AmqpOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.cassandra.config.xml.CassandraOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractConsumerEndpointParser
-
Parse the MessageHandler.
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ServiceActivatorParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractRouterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractTransformerParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AggregatorParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.BarrierParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.BridgeParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ChainParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ControlBusParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.DelayerParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.EnricherParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ResequencerParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ScatterGatherParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.file.config.AbstractRemoteFileOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.file.config.FileOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.file.config.FileSplitterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.groovy.config.GroovyControlBusParser
-
Deprecated.
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.http.config.HttpOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.ip.config.TcpOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jms.config.JmsOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jmx.config.OperationInvokingOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jpa.config.xml.AbstractJpaOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jpa.config.xml.RetrievingJpaOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jpa.config.xml.UpdatingJpaOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.kafka.config.xml.KafkaOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.mongodb.config.MongoDbOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisQueueOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.rsocket.config.RSocketOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.ws.config.WebServiceOutboundGatewayParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.xml.config.XmlPayloadValidatingFilterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.xml.config.XPathFilterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.xml.config.XPathMessageSplitterParser
- parseInnerHandlerDefinition(Element, ParserContext) - Static method in class org.springframework.integration.config.xml.IntegrationNamespaceUtils
- parseInt(int) - Static method in enum class org.springframework.integration.syslog.RFC5424SyslogParser.Severity
- parseInterceptors(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ChannelInterceptorParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractChannelAdapterParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractChannelParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractConsumerEndpointParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ConverterParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.GlobalChannelInterceptorParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.IdempotentReceiverInterceptorParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.IntegrationManagementParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.PollerParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.PublishingInterceptorParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.RetryAdviceParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.config.xml.TransactionSynchronizationFactoryParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.ip.config.TcpConnectionFactoryParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcMessageStoreParser
- parseInternal(Element, ParserContext) - Method in class org.springframework.integration.zookeeper.config.xml.LeaderListenerParser
- PARSER - Static variable in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
- PARSER - Static variable in class org.springframework.integration.dsl.GatewayProxySpec
- PARSER - Static variable in class org.springframework.integration.dsl.IntegrationComponentSpec
- PARSER - Static variable in class org.springframework.integration.support.MapBuilder
- parseRemoteFileTemplate(Element, ParserContext, boolean, Class<? extends RemoteFileOperations<?>>) - Static method in class org.springframework.integration.file.config.FileParserUtils
- parseReturnVariable(String) - Static method in class org.springframework.integration.scripting.jsr223.PythonScriptExecutor.PythonVariableParser
-
Deprecated.
- parseRouter(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractRouterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractPollingInboundChannelAdapterParser
-
Subclasses must implement this method to parse the PollableSource instance which the created Channel Adapter will poll.
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.config.xml.DefaultInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ResourceInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.feed.config.FeedInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.file.config.AbstractRemoteFileInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.file.config.AbstractRemoteFileStreamingInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.file.config.FileInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.hazelcast.config.xml.HazelcastDistributedSQLInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcPollingChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jms.config.JmsInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jmx.config.AttributePollingChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jmx.config.MBeanTreePollingChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.jpa.config.xml.JpaInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.kafka.config.xml.KafkaInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.mail.config.MailInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.mongodb.config.MongoDbInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.redis.config.RedisStoreInboundChannelAdapterParser
- parseSource(Element, ParserContext) - Method in class org.springframework.integration.stream.config.ConsoleInboundChannelAdapterParser
- parseStructuredDataElements(RFC5424SyslogParser.Reader) - Method in class org.springframework.integration.syslog.RFC5424SyslogParser
-
Default implementation returns a list of structured data elements with no internal parsing.
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.AbstractTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.ClaimCheckInParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.ClaimCheckOutParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.HeaderEnricherParserSupport
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.HeaderFilterParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.JsonToObjectTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.MapToObjectTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.ObjectToJsonTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.ObjectToMapTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.ObjectToStringTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.PayloadDeserializingTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.PayloadSerializingTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.config.xml.SyslogToMapTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.file.config.AbstractFilePayloadTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.mail.config.MailToStringTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xml.config.MarshallingTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xml.config.UnmarshallingTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xml.config.XPathHeaderEnricherParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xml.config.XPathTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xml.config.XsltPayloadTransformerParser
- parseTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.zip.config.xml.AbstractZipTransformerParser
- parseUrl(Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractOutboundGatewayParser
- parseWithHeaders(JsonParser, String, Map<String, Object>) - Method in class org.springframework.integration.support.json.Jackson2JsonMessageParser
- PartialSuccessException - Exception in org.springframework.integration.support
-
A
MessagingException
thrown when a non-transactional operation is performing multiple updates from a single message, e.g. - PartialSuccessException(Message<?>, String, Throwable, Collection<?>, Collection<?>) - Constructor for exception org.springframework.integration.support.PartialSuccessException
- partitioned(int) - Method in class org.springframework.integration.dsl.Channels
-
Create a
PartitionedChannelSpec
. - partitioned(int) - Static method in class org.springframework.integration.dsl.MessageChannels
-
Create a
PartitionedChannelSpec
. - partitioned(String, int) - Method in class org.springframework.integration.dsl.Channels
-
Create a
PartitionedChannelSpec
. - partitioned(String, int) - Static method in class org.springframework.integration.dsl.MessageChannels
-
Create a
PartitionedChannelSpec
. - PartitionedChannel - Class in org.springframework.integration.channel
-
An
AbstractExecutorChannel
implementation for partitioned message dispatching. - PartitionedChannel(int) - Constructor for class org.springframework.integration.channel.PartitionedChannel
-
Instantiate based on a provided number of partitions and function resolving a partition key from the
IntegrationMessageHeaderAccessor.CORRELATION_ID
message header. - PartitionedChannel(int, Function<Message<?>, Object>) - Constructor for class org.springframework.integration.channel.PartitionedChannel
-
Instantiate based on a provided number of partitions and function for partition key against the message.
- PartitionedChannelSpec - Class in org.springframework.integration.dsl
-
A
LoadBalancingChannelSpec
implementation for thePartitionedChannel
. - PartitionedChannelSpec(int) - Constructor for class org.springframework.integration.dsl.PartitionedChannelSpec
- PartitionedDispatcher - Class in org.springframework.integration.dispatcher
-
An
AbstractDispatcher
implementation for distributing messages to dedicated threads according to the key determined by the provided function against the message to dispatch. - PartitionedDispatcher(int, Function<Message<?>, Object>) - Constructor for class org.springframework.integration.dispatcher.PartitionedDispatcher
-
Instantiate based on a provided number of partitions and function for partition key against the message to dispatch.
- partitionId(Integer) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
-
Configure a partitionId of Kafka topic.
- partitionId(Function<Message<P>, Integer>) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
-
Configure a
Function
that will be invoked at runtime to determine the partition id under which a message will be stored in the topic. - partitionIdExpression(String) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
-
Configure a SpEL expression to determine the topic partitionId at runtime against request Message as a root object of evaluation context.
- partitionIdExpression(Expression) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
-
Configure an
Expression
to determine the topic partitionId at runtime against request Message as a root object of evaluation context. - partitionKey(Function<Message<?>, Object>) - Method in class org.springframework.integration.dsl.PartitionedChannelSpec
- PASSCODE - Static variable in class org.springframework.integration.stomp.support.IntegrationStompHeaders
- PassThroughTransactionSynchronizationFactory - Class in org.springframework.integration.transaction
-
A simple
TransactionSynchronizationFactory
implementation which produces anIntegrationResourceHolderSynchronization
with anIntegrationResourceHolder
. - PassThroughTransactionSynchronizationFactory() - Constructor for class org.springframework.integration.transaction.PassThroughTransactionSynchronizationFactory
- PassThruLockRegistry - Class in org.springframework.integration.support.locks
-
The
LockRegistry
implementation which has no effect. - PassThruLockRegistry() - Constructor for class org.springframework.integration.support.locks.PassThruLockRegistry
- PassThruMessageConverter - Class in org.springframework.integration.support.converter
-
The simple
MessageConverter
implementation which contract is to returnMessage
as is for bothfrom/to
operations. - PassThruMessageConverter() - Constructor for class org.springframework.integration.support.converter.PassThruMessageConverter
- PassThruSubProtocolHandler - Class in org.springframework.integration.websocket.support
-
The simple 'pass thru'
SubProtocolHandler
, when there is no interests in the WebSocket sub-protocols. - PassThruSubProtocolHandler() - Constructor for class org.springframework.integration.websocket.support.PassThruSubProtocolHandler
- password(String) - Method in class org.springframework.integration.mail.dsl.MailSendingMessageHandlerSpec
-
Set the mail user password.
- path() - Element in annotation interface org.springframework.integration.http.config.EnableIntegrationGraphController
-
Specify the Request Mapping path for the
IntegrationGraphController
. - pathFor(String) - Method in interface org.springframework.integration.zookeeper.lock.ZookeeperLockRegistry.KeyToPathStrategy
-
Return the path for the key.
- PathMovedEvent - Class in org.springframework.integration.ftp.server
-
An event emitted when a path is moved.
- PathMovedEvent - Class in org.springframework.integration.sftp.server
-
An event emitted when a path is moved.
- PathMovedEvent(Object, Path, Path, Throwable) - Constructor for class org.springframework.integration.sftp.server.PathMovedEvent
- PathMovedEvent(FtpSession, FtpRequest) - Constructor for class org.springframework.integration.ftp.server.PathMovedEvent
- PathRemovedEvent - Class in org.springframework.integration.ftp.server
-
An event emitted when a file or directory is removed.
- PathRemovedEvent - Class in org.springframework.integration.sftp.server
-
An event emitted when a file or directory is removed.
- PathRemovedEvent(Object, Path, boolean, Throwable) - Constructor for class org.springframework.integration.sftp.server.PathRemovedEvent
- PathRemovedEvent(FtpSession, FtpRequest, boolean) - Constructor for class org.springframework.integration.ftp.server.PathRemovedEvent
- PatternBasedHeaderMatcher(Collection<String>) - Constructor for class org.springframework.integration.mapping.AbstractHeaderMapper.PatternBasedHeaderMatcher
- patternFileNameFilter(String) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec
-
Specify a simple pattern to match remote files (e.g.
- patternFileNameFilter(String) - Method in class org.springframework.integration.ftp.dsl.FtpOutboundGatewaySpec
- patternFileNameFilter(String) - Method in class org.springframework.integration.sftp.dsl.SftpOutboundGatewaySpec
- patternFileNameFilter(String) - Method in class org.springframework.integration.smb.dsl.SmbOutboundGatewaySpec
- patternFilter(String) - Method in class org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec
-
Configure a
SimplePatternFileListFilter
. - patternFilter(String) - Method in class org.springframework.integration.file.dsl.RemoteFileInboundChannelAdapterSpec
-
Configure a simple pattern filter (e.g.
- patternFilter(String) - Method in class org.springframework.integration.file.dsl.RemoteFileStreamingInboundChannelAdapterSpec
-
Configure a simple pattern filter (e.g.
- patternFilter(String) - Method in class org.springframework.integration.ftp.dsl.FtpInboundChannelAdapterSpec
-
Specify a simple pattern to match remote files.
- patternFilter(String) - Method in class org.springframework.integration.ftp.dsl.FtpStreamingInboundChannelAdapterSpec
-
Specify a simple pattern to match remote files (e.g.
- patternFilter(String) - Method in class org.springframework.integration.sftp.dsl.SftpInboundChannelAdapterSpec
- patternFilter(String) - Method in class org.springframework.integration.sftp.dsl.SftpStreamingInboundChannelAdapterSpec
-
Specify a simple pattern to match remote files (e.g.
- patternFilter(String) - Method in class org.springframework.integration.smb.dsl.SmbInboundChannelAdapterSpec
-
Specify a simple pattern to match remote files.
- patternFilter(String) - Method in class org.springframework.integration.smb.dsl.SmbStreamingInboundChannelAdapterSpec
-
Specify a simple pattern to match remote files (e.g.
- patternMatch(boolean) - Method in class org.springframework.integration.dsl.HeaderFilterSpec
- PatternMatchUtils - Class in org.springframework.integration.support.utils
-
Utility methods for pattern matching.
- patternMputFilter(String) - Method in class org.springframework.integration.file.dsl.RemoteFileOutboundGatewaySpec
-
A
SimplePatternFileListFilter
that runs against the local file system view when usingMPUT
command. - patterns() - Element in annotation interface org.springframework.integration.config.GlobalChannelInterceptor
-
An array of patterns against which channel names will be matched.
- Pausable - Interface in org.springframework.integration.core
-
Endpoints implementing this interface can be paused/resumed.
- pause() - Method in interface org.springframework.integration.core.Pausable
-
Pause the endpoint.
- pause() - Method in class org.springframework.integration.kafka.inbound.KafkaInboundGateway
- pause() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
- pause() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageSource
- PayloadAndHeaderMatcher<T> - Class in org.springframework.integration.test.matcher
-
Matcher to make assertions about message equality easier.
- PayloadDeserializingTransformer - Class in org.springframework.integration.transformer
-
Transformer that deserializes the inbound byte array payload to an object by delegating to a Converter<byte[], Object>.
- PayloadDeserializingTransformer() - Constructor for class org.springframework.integration.transformer.PayloadDeserializingTransformer
-
Instantiate based on the
AllowListDeserializingConverter
with theDefaultDeserializer
. - PayloadDeserializingTransformerParser - Class in org.springframework.integration.config.xml
-
Parser for the 'payload-deserializing-transformer' element.
- PayloadDeserializingTransformerParser() - Constructor for class org.springframework.integration.config.xml.PayloadDeserializingTransformerParser
- payloadExpression() - Element in annotation interface org.springframework.integration.annotation.Gateway
-
Specify a SpEL expression to determine the payload of the request message.
- payloadExpression(String) - Method in class org.springframework.integration.dsl.GatewayProxySpec
-
An expression that will be used to generate the
payload
for all methods in the service interface unless explicitly overridden by a method declaration. - payloadExpression(String) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec
-
Specify a SpEL expression to evaluate in order to generate the Message payload.
- payloadExpression(Expression) - Method in class org.springframework.integration.dsl.GatewayProxySpec
-
An expression that will be used to generate the
payload
for all methods in the service interface unless explicitly overridden by a method declaration. - payloadExpression(Expression) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec
-
Specify a SpEL expression to evaluate in order to generate the Message payload.
- PayloadExpressionArgumentResolver - Class in org.springframework.integration.handler.support
-
The
HandlerMethodArgumentResolver
for evaluatingPayload.expression()
as a SpEL expression againstmessage
and converting result to expected parameter type. - PayloadExpressionArgumentResolver() - Constructor for class org.springframework.integration.handler.support.PayloadExpressionArgumentResolver
- payloadFunction(Function<HttpEntity<P>, ?>) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec
-
Specify a
Function
to evaluate in order to generate the Message payload. - payloadFunction(Function<MethodArgsHolder, ?>) - Method in class org.springframework.integration.dsl.GatewayProxySpec
-
A
Function
that will be used to generate thepayload
for all methods in the service interface unless explicitly overridden by a method declaration. - PayloadMatcher<T> - Class in org.springframework.integration.test.matcher
-
Is the payload of a
Message
equal to a given value or is matching a given matcher? - Payloads - Annotation Interface in org.springframework.integration.annotation
-
This annotation marks a method parameter as being a list of message payloads, for POJO handlers that deal with lists of messages (e.g.
- PayloadsArgumentResolver - Class in org.springframework.integration.handler.support
-
The
HandlerMethodArgumentResolver
for resolving aCollection
ofpayloads
or expression against eachpayload
. - PayloadsArgumentResolver() - Constructor for class org.springframework.integration.handler.support.PayloadsArgumentResolver
- PayloadSerializingTransformer - Class in org.springframework.integration.transformer
-
Transformer that serializes the inbound payload into a byte array by delegating to a Converter<Object, byte[]>.
- PayloadSerializingTransformer() - Constructor for class org.springframework.integration.transformer.PayloadSerializingTransformer
-
Instantiate based on the
SerializingConverter
with theDefaultSerializer
. - PayloadSerializingTransformerParser - Class in org.springframework.integration.config.xml
-
Parser for the 'payload-serializing-transformer' element.
- PayloadSerializingTransformerParser() - Constructor for class org.springframework.integration.config.xml.PayloadSerializingTransformerParser
- payloadType - Variable in class org.springframework.integration.support.json.AbstractJsonInboundMessageMapper
- payloadType(Class<?>) - Method in class org.springframework.integration.kafka.dsl.KafkaInboundChannelAdapterSpec
-
Set the payload type.
- payloadType(Class<?>) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec
-
When using a type-aware message converter (such as
StringJsonMessageConverter
), set the payload type the converter should create. - payloadType(Class<?>) - Method in class org.springframework.integration.r2dbc.dsl.R2dbcMessageSourceSpec
-
Set the expected payload type.
- PayloadTypeConvertingTransformer<T,
U> - Class in org.springframework.integration.transformer -
Transformer that converts the inbound payload to an object by delegating to a Converter<Object, Object>.
- PayloadTypeConvertingTransformer() - Constructor for class org.springframework.integration.transformer.PayloadTypeConvertingTransformer
- PayloadTypeRouter - Class in org.springframework.integration.router
-
A Message Router that resolves the
MessageChannel
based on theMessage's
payload type. - PayloadTypeRouter() - Constructor for class org.springframework.integration.router.PayloadTypeRouter
- PayloadTypeRouterParser - Class in org.springframework.integration.config.xml
-
Parser for the <payload-type-router/> element.
- PayloadTypeRouterParser() - Constructor for class org.springframework.integration.config.xml.PayloadTypeRouterParser
- PayloadTypeSelector - Class in org.springframework.integration.selector
-
A
MessageSelector
implementation that checks the type of theMessage
payload. - PayloadTypeSelector(Class<?>...) - Constructor for class org.springframework.integration.selector.PayloadTypeSelector
-
Create a selector for the provided types.
- PayloadValidator<T> - Class in org.springframework.integration.test.support
-
Validate a message payload.
- PayloadValidator() - Constructor for class org.springframework.integration.test.support.PayloadValidator
- payloadWhenNull(AttributeAccessor) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Build a
Throwable payload
based on the provided context for futureErrorMessage
when there is originalThrowable
. - payloadWhenNull(AttributeAccessor) - Method in class org.springframework.integration.handler.advice.ErrorMessageSendingRecoverer
- peek() - Method in class org.springframework.integration.store.MessageGroupQueue
- peek() - Method in class org.springframework.integration.syslog.RFC5424SyslogParser.Reader
- performReceive(Long) - Method in class org.springframework.integration.amqp.channel.PollableAmqpChannel
- PeriodicTriggerFactoryBean - Class in org.springframework.integration.config
-
The
FactoryBean
to produce aPeriodicTrigger
based on parsing string values for its options. - PeriodicTriggerFactoryBean() - Constructor for class org.springframework.integration.config.PeriodicTriggerFactoryBean
- persist(Object) - Method in class org.springframework.integration.jpa.core.DefaultJpaOperations
- persist(Object) - Method in interface org.springframework.integration.jpa.core.JpaOperations
-
Persists the entity.
- persist(Object, int, boolean) - Method in class org.springframework.integration.jpa.core.DefaultJpaOperations
- persist(Object, int, boolean) - Method in interface org.springframework.integration.jpa.core.JpaOperations
-
Persists the entity.
- PERSIST - Enum constant in enum class org.springframework.integration.jpa.support.PersistMode
- PERSISTENT - Enum constant in enum class org.springframework.integration.store.SimpleMessageGroupFactory.GroupType
- persistLocation() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource
- persistMode(PersistMode) - Method in class org.springframework.integration.jpa.dsl.JpaUpdatingOutboundEndpointSpec
-
Specify a
PersistMode
for the gateway. - PersistMode - Enum Class in org.springframework.integration.jpa.support
-
Indicates how entities shall be persisted to the underlying persistence store.
- persistName() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource
- persistPeriod() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource
- persistPolicy() - Element in annotation interface org.springframework.integration.support.management.IntegrationManagedResource
- PgConnectionSupplier - Interface in org.springframework.integration.jdbc.channel
-
A connection supplier for a
PgConnection
to a Postgres database that is to be used for aPostgresChannelMessageTableSubscriber
. - phase() - Element in annotation interface org.springframework.integration.annotation.Aggregator
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.BridgeFrom
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.BridgeTo
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.Filter
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.InboundChannelAdapter
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.Router
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.ServiceActivator
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.Splitter
-
Specify a
SmartLifecycle
phase
option. - phase() - Element in annotation interface org.springframework.integration.annotation.Transformer
-
Specify a
SmartLifecycle
phase
option. - phase(int) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec
- phase(int) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec
- phase(int) - Method in class org.springframework.integration.dsl.EndpointSpec
- phase(int) - Method in class org.springframework.integration.dsl.MessageProducerSpec
- phase(int) - Method in class org.springframework.integration.dsl.MessagingGatewaySpec
-
A lifecycle phase to use.
- phase(int) - Method in class org.springframework.integration.dsl.SourcePollingChannelAdapterSpec
- phase(int) - Method in class org.springframework.integration.file.dsl.TailAdapterSpec
- phase(int) - Method in class org.springframework.integration.jms.dsl.JmsMessageChannelSpec
- PHASE - Static variable in class org.springframework.integration.config.xml.IntegrationNamespaceUtils
- PointToPointChannelParser - Class in org.springframework.integration.config.xml
-
Parser for the <channel> element.
- PointToPointChannelParser() - Constructor for class org.springframework.integration.config.xml.PointToPointChannelParser
- PointToPointSubscribableAmqpChannel - Class in org.springframework.integration.amqp.channel
-
The
AbstractSubscribableAmqpChannel
implementation for one-to-one subscription over AMQP queue. - PointToPointSubscribableAmqpChannel(String, AbstractMessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.channel.PointToPointSubscribableAmqpChannel
-
Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.
- PointToPointSubscribableAmqpChannel(String, AbstractMessageListenerContainer, AmqpTemplate, AmqpHeaderMapper, AmqpHeaderMapper) - Constructor for class org.springframework.integration.amqp.channel.PointToPointSubscribableAmqpChannel
-
Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.
- PojoCodec - Class in org.springframework.integration.codec.kryo
-
Kryo Codec that can encode and decode arbitrary types.
- PojoCodec() - Constructor for class org.springframework.integration.codec.kryo.PojoCodec
- PojoCodec(List<KryoRegistrar>) - Constructor for class org.springframework.integration.codec.kryo.PojoCodec
-
Create an instance with zero to many KryoRegistrars.
- PojoCodec(List<KryoRegistrar>, boolean) - Constructor for class org.springframework.integration.codec.kryo.PojoCodec
-
Create an instance with zero to many KryoRegistrars.
- PojoCodec(KryoRegistrar) - Constructor for class org.springframework.integration.codec.kryo.PojoCodec
-
Create an instance with a single KryoRegistrar.
- PojoCodec(KryoRegistrar, boolean) - Constructor for class org.springframework.integration.codec.kryo.PojoCodec
-
Create an instance with a single KryoRegistrar.
- poll() - Method in class org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource
- poll() - Method in class org.springframework.integration.jpa.core.JpaExecutor
-
Execute the JPA operation.
- poll() - Method in class org.springframework.integration.store.MessageGroupQueue
- poll(long, TimeUnit) - Method in class org.springframework.integration.store.MessageGroupQueue
- poll(Message<?>) - Method in class org.springframework.integration.jpa.core.JpaExecutor
-
Execute a (typically retrieving) JPA operation.
- poll(MessageHandler) - Method in class org.springframework.integration.endpoint.MessageSourcePollingTemplate
- poll(MessageHandler) - Method in interface org.springframework.integration.endpoint.PollingOperations
-
Poll for a message.
- pollable_channel - Enum constant in enum class org.springframework.integration.IntegrationPatternType
- PollableAmqpChannel - Class in org.springframework.integration.amqp.channel
-
A
PollableChannel
implementation that is backed by an AMQP Queue. - PollableAmqpChannel(String, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.channel.PollableAmqpChannel
-
Construct an instance with the supplied name, template and default header mappers used if the template is a
RabbitTemplate
and the message is mapped. - PollableAmqpChannel(String, AmqpTemplate, AmqpHeaderMapper, AmqpHeaderMapper) - Constructor for class org.springframework.integration.amqp.channel.PollableAmqpChannel
-
Construct an instance with the supplied name, template and header mappers.
- pollableChannel(ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
-
The factory to produce a
JmsPollableMessageChannelSpec
. - pollableChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
-
The factory to produce a
JmsPollableMessageChannelSpec
. - pollableChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp
-
Create an initial AmqpPollableMessageChannelSpec.
- pollableChannel(ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp
-
Create an initial AmqpPollableMessageChannelSpec.
- pollableChannel(KafkaTemplate<?, ?>, KafkaMessageSource<?, ?>) - Static method in class org.springframework.integration.kafka.dsl.Kafka
-
Create a spec for a pollable channel with the provided parameters.
- PollableChannelNode - Class in org.springframework.integration.graph
-
Represents a pollable channel.
- PollableChannelNode(int, String, MessageChannel) - Constructor for class org.springframework.integration.graph.PollableChannelNode
- PollableJmsChannel - Class in org.springframework.integration.jms
- PollableJmsChannel(JmsTemplate) - Constructor for class org.springframework.integration.jms.PollableJmsChannel
- PollableKafkaChannel - Class in org.springframework.integration.kafka.channel
-
Pollable channel backed by an Apache Kafka topic.
- PollableKafkaChannel(KafkaOperations<?, ?>, KafkaMessageSource<?, ?>) - Constructor for class org.springframework.integration.kafka.channel.PollableKafkaChannel
-
Construct an instance with the provided parameters.
- poller() - Element in annotation interface org.springframework.integration.annotation.Aggregator
- poller() - Element in annotation interface org.springframework.integration.annotation.BridgeFrom
- poller() - Element in annotation interface org.springframework.integration.annotation.BridgeTo
- poller() - Element in annotation interface org.springframework.integration.annotation.Filter
- poller() - Element in annotation interface org.springframework.integration.annotation.InboundChannelAdapter
- poller() - Element in annotation interface org.springframework.integration.annotation.Router
- poller() - Element in annotation interface org.springframework.integration.annotation.ServiceActivator
- poller() - Element in annotation interface org.springframework.integration.annotation.Splitter
- poller() - Element in annotation interface org.springframework.integration.annotation.Transformer
- poller(Function<PollerFactory, PollerSpec>) - Method in class org.springframework.integration.dsl.EndpointSpec
- poller(PollerSpec) - Method in class org.springframework.integration.dsl.EndpointSpec
- poller(PollerMetadata) - Method in class org.springframework.integration.dsl.ConsumerEndpointSpec
- poller(PollerMetadata) - Method in class org.springframework.integration.dsl.EndpointSpec
- poller(PollerMetadata) - Method in class org.springframework.integration.dsl.SourcePollingChannelAdapterSpec
- Poller - Annotation Interface in org.springframework.integration.annotation
-
Provides the
PollerMetadata
options for the Messaging annotations for polled endpoints. - PollerFactory - Class in org.springframework.integration.dsl
-
An
Adapter
class for thePollers
factory. - PollerMetadata - Class in org.springframework.integration.scheduling
- PollerMetadata() - Constructor for class org.springframework.integration.scheduling.PollerMetadata
- PollerParser - Class in org.springframework.integration.config.xml
-
Parser for the <poller> element.
- PollerParser() - Constructor for class org.springframework.integration.config.xml.PollerParser
- Pollers - Class in org.springframework.integration.dsl
-
A utility class to provide
PollerSpec
s forPollerMetadata
configuration variants. - PollerSpec - Class in org.springframework.integration.dsl
-
An
IntegrationComponentSpec
forPollerMetadata
s. - PollingConsumer - Class in org.springframework.integration.endpoint
-
Message Endpoint that connects any
MessageHandler
implementation to aPollableChannel
. - PollingConsumer(PollableChannel, MessageHandler) - Constructor for class org.springframework.integration.endpoint.PollingConsumer
- PollingOperations - Interface in org.springframework.integration.endpoint
-
Operations to perform on some message source.
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Poll the database for a new message that is persisted for the given group id which represents the channel identifier.
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.mongodb.store.MongoDbChannelMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.mongodb.store.MongoDbMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.redis.store.RedisChannelMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.redis.store.RedisChannelPriorityMessageStore
- pollMessageFromGroup(Object) - Method in class org.springframework.integration.store.AbstractKeyValueMessageStore
- pollMessageFromGroup(Object) - Method in interface org.springframework.integration.store.BasicMessageGroupStore
-
Poll Message from this
MessageGroup
(in FIFO style if supported by the implementation) while also removing the polledMessage
. - pollMessageFromGroup(Object) - Method in class org.springframework.integration.store.SimpleMessageStore
- PollSkipAdvice - Class in org.springframework.integration.scheduling
-
An advice that can be added to a poller's advice chain that determines whether a poll should be skipped or not.
- PollSkipAdvice() - Constructor for class org.springframework.integration.scheduling.PollSkipAdvice
- PollSkipAdvice(PollSkipStrategy) - Constructor for class org.springframework.integration.scheduling.PollSkipAdvice
- PollSkipStrategy - Interface in org.springframework.integration.scheduling
-
Implementations determine whether a particular poll should be skipped.
- pollTimeout(long) - Method in class org.springframework.integration.kafka.dsl.KafkaMessageListenerContainerSpec
-
Set the max time to block in the consumer waiting for records.
- PolyglotScriptExecutor - Class in org.springframework.integration.scripting
-
GraalVM Polyglot
ScriptExecutor
implementation. - PolyglotScriptExecutor(String) - Constructor for class org.springframework.integration.scripting.PolyglotScriptExecutor
-
Construct an executor based on the provided language id.
- PolyglotScriptExecutor(String, Context.Builder) - Constructor for class org.springframework.integration.scripting.PolyglotScriptExecutor
-
Construct an executor based on the provided language id.
- pool - Variable in class org.springframework.integration.codec.kryo.AbstractKryoCodec
- Pool<T> - Interface in org.springframework.integration.util
-
Represents a pool of items.
- PoolItemNotAvailableException - Exception in org.springframework.integration.util
-
Thrown when a pooled item could not be obtained for some reason.
- PoolItemNotAvailableException(String) - Constructor for exception org.springframework.integration.util.PoolItemNotAvailableException
- PoolItemNotAvailableException(String, Throwable) - Constructor for exception org.springframework.integration.util.PoolItemNotAvailableException
- poolSize(int) - Method in class org.springframework.integration.ip.dsl.UdpInboundChannelAdapterSpec
- pop3InboundAdapter() - Static method in class org.springframework.integration.mail.dsl.Mail
-
A
Pop3MailInboundChannelAdapterSpec
factory using a defaultPop3MailReceiver
. - pop3InboundAdapter(String) - Static method in class org.springframework.integration.mail.dsl.Mail
-
A
Pop3MailInboundChannelAdapterSpec
factory based on the provided url. - pop3InboundAdapter(String, int, String, String) - Static method in class org.springframework.integration.mail.dsl.Mail
-
A
Pop3MailInboundChannelAdapterSpec
factory based on the provided host, port, user, and password. - pop3InboundAdapter(String, String, String) - Static method in class org.springframework.integration.mail.dsl.Mail
-
A
Pop3MailInboundChannelAdapterSpec
factory based on the provided host, user, password and the default port. - pop3InboundAdapter(Pop3MailReceiver) - Static method in class org.springframework.integration.mail.dsl.Mail
-
A
Pop3MailInboundChannelAdapterSpec
factory based on the providedPop3MailReceiver
. - Pop3MailInboundChannelAdapterSpec - Class in org.springframework.integration.mail.dsl
-
A
MailInboundChannelAdapterSpec
for POP3. - Pop3MailInboundChannelAdapterSpec() - Constructor for class org.springframework.integration.mail.dsl.Pop3MailInboundChannelAdapterSpec
- Pop3MailInboundChannelAdapterSpec(String) - Constructor for class org.springframework.integration.mail.dsl.Pop3MailInboundChannelAdapterSpec
- Pop3MailInboundChannelAdapterSpec(String, int, String, String) - Constructor for class org.springframework.integration.mail.dsl.Pop3MailInboundChannelAdapterSpec
- Pop3MailInboundChannelAdapterSpec(String, String, String) - Constructor for class org.springframework.integration.mail.dsl.Pop3MailInboundChannelAdapterSpec
- Pop3MailInboundChannelAdapterSpec(Pop3MailReceiver) - Constructor for class org.springframework.integration.mail.dsl.Pop3MailInboundChannelAdapterSpec
- Pop3MailReceiver - Class in org.springframework.integration.mail
-
A
MailReceiver
implementation that polls a mail server using the POP3 protocol. - Pop3MailReceiver() - Constructor for class org.springframework.integration.mail.Pop3MailReceiver
- Pop3MailReceiver(String) - Constructor for class org.springframework.integration.mail.Pop3MailReceiver
- Pop3MailReceiver(String, int, String, String) - Constructor for class org.springframework.integration.mail.Pop3MailReceiver
- Pop3MailReceiver(String, String, String) - Constructor for class org.springframework.integration.mail.Pop3MailReceiver
- popSequence(boolean) - Method in class org.springframework.integration.dsl.CorrelationHandlerSpec
-
Perform a
BaseMessageBuilder.popSequenceDetails()
for output message or not. - popSequenceDetails() - Method in class org.springframework.integration.support.AbstractIntegrationMessageBuilder
- popSequenceDetails() - Method in class org.springframework.integration.support.BaseMessageBuilder
- populateJavaTypes(Map<String, Object>, Object) - Method in interface org.springframework.integration.support.json.JsonObjectMapper
- populatePropagatedContext(Observation, Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.ObservationPropagationChannelInterceptor
-
Deprecated.
- populatePropagatedContext(S, Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.ThreadStatePropagationChannelInterceptor
- populateStandardHeaders(Map<String, Object>, Map<String, Object>, MessageProperties) - Method in class org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper
-
Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message.
- populateStandardHeaders(Map<String, Object>, Map<String, Object>, T) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper
-
Populate the specified standard headers to the specified source.
- populateStandardHeaders(Map<String, Object>, MessageBuilder) - Method in class org.springframework.integration.xmpp.support.DefaultXmppHeaderMapper
- populateStandardHeaders(Map<String, Object>, MessageProperties) - Method in class org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper
-
Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message.
- populateStandardHeaders(Map<String, Object>, SoapMessage) - Method in class org.springframework.integration.ws.DefaultSoapHeaderMapper
- populateStandardHeaders(Map<String, Object>, T) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper
-
Populate the specified standard headers to the specified source.
- populateUserDefinedHeader(String, Object, MessageBuilder) - Method in class org.springframework.integration.xmpp.support.DefaultXmppHeaderMapper
- populateUserDefinedHeader(String, Object, MessageProperties) - Method in class org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper
- populateUserDefinedHeader(String, Object, SoapMessage) - Method in class org.springframework.integration.ws.DefaultSoapHeaderMapper
- populateUserDefinedHeader(String, Object, T) - Method in class org.springframework.integration.mapping.AbstractHeaderMapper
-
Populate the specified user-defined headers to the specified source.
- port(int) - Method in class org.springframework.integration.mail.dsl.MailSendingMessageHandlerSpec
-
Set the port.
- PORT - Static variable in class org.springframework.integration.ip.IpHeaders
-
The remote port for a UDP packet.
- PositionSupportingParameterSource - Interface in org.springframework.integration.jpa.support.parametersource
- PostgresChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
- PostgresChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
- PostgresChannelMessageTableSubscriber - Class in org.springframework.integration.jdbc.channel
-
A subscriber for new messages being received by a Postgres database via a
JdbcChannelMessageStore
. - PostgresChannelMessageTableSubscriber(PgConnectionSupplier) - Constructor for class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Create a new subscriber using the
JdbcChannelMessageStore.DEFAULT_TABLE_PREFIX
. - PostgresChannelMessageTableSubscriber(PgConnectionSupplier, String) - Constructor for class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Create a new subscriber.
- PostgresChannelMessageTableSubscriber.Subscription - Interface in org.springframework.integration.jdbc.channel
-
A subscription to a
PostgresChannelMessageTableSubscriber
for receiving push notifications for new messages that are added to aJdbcChannelMessageStore
. - PostgresSubscribableChannel - Class in org.springframework.integration.jdbc.channel
-
An
AbstractSubscribableChannel
for receiving push notifications for messages send to a group id of aJdbcChannelMessageStore
. - PostgresSubscribableChannel(JdbcChannelMessageStore, Object, PostgresChannelMessageTableSubscriber) - Constructor for class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
-
Create a subscribable channel for a Postgres database.
- postProcess(Object, String, Method, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor
- postProcess(Object, String, Method, List<Annotation>) - Method in interface org.springframework.integration.config.annotation.MethodAnnotationPostProcessor
- postProcess(Object, String, Method, List<Annotation>) - Method in class org.springframework.integration.config.InboundChannelAdapterAnnotationPostProcessor
- postProcess(Object, ScriptEngine, String, Bindings) - Method in class org.springframework.integration.scripting.jsr223.AbstractScriptExecutor
-
Subclasses may implement this to provide any special handling required
- postProcess(Object, ScriptEngine, String, Bindings) - Method in class org.springframework.integration.scripting.jsr223.DefaultScriptExecutor
- postProcess(Object, ScriptEngine, String, Bindings) - Method in class org.springframework.integration.scripting.jsr223.PythonScriptExecutor
-
Deprecated.
- postProcess(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.config.xml.AbstractInboundGatewayParser
- postProcess(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.config.xml.DefaultRouterParser
- postProcess(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.groovy.config.GroovyScriptParser
- postProcess(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.scripting.config.AbstractScriptParser
-
Subclasses may override this no-op method to provide additional configuration.
- postProcess(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.scripting.config.jsr223.ScriptParser
- postProcess(Message<?>, Object) - Method in class org.springframework.integration.filter.MessageFilter
- postProcess(Message<?>, Object) - Method in interface org.springframework.integration.handler.PostProcessingMessageHandler
-
Take some further action on the result and/or message.
- postProcess(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xmpp.config.AbstractXmppInboundChannelAdapterParser
- postProcess(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.xmpp.config.ChatMessageInboundChannelAdapterParser
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.config.GlobalChannelInterceptorProcessor
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.config.IntegrationManagementConfigurer
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.config.MessagingAnnotationBeanPostProcessor
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.monitor.IntegrationMBeanExporter
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.support.management.ControlBusCommandRegistry
- postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor
- postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.integration.config.IntegrationConfigurationBeanFactoryPostProcessor
- postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.integration.config.MessagingAnnotationPostProcessor
- postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor
- postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.integration.config.FixedSubscriberChannelBeanFactoryPostProcessor
- postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.integration.config.IntegrationConfigurationBeanFactoryPostProcessor
- postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.integration.config.MessagingAnnotationPostProcessor
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition.ReplyProducerCleaner
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.history.MessageHistoryConfigurer
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.http.inbound.DynamicRequestMappingBeanPostProcessor
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.monitor.IntegrationMBeanExporter
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.support.management.ControlBusCommandRegistry
- postProcessBeforeDestruction(Object, String) - Method in class org.springframework.integration.webflux.inbound.WebFluxIntegrationRequestMappingHandlerMapping
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.dsl.context.IntegrationFlowBeanPostProcessor
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.history.MessageHistoryConfigurer
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.http.inbound.DynamicRequestMappingBeanPostProcessor
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.test.context.MockIntegrationContext
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.webflux.inbound.WebFluxIntegrationRequestMappingHandlerMapping
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.file.config.AbstractRemoteFileOutboundGatewayParser
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.file.config.RemoteFileOutboundChannelAdapterParser
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.ftp.config.FtpOutboundChannelAdapterParser
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.ftp.config.FtpOutboundGatewayParser
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.sftp.config.SftpOutboundChannelAdapterParser
- postProcessBuilder(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.sftp.config.SftpOutboundGatewayParser
- postProcessClientAfterConnect(FTPSClient) - Method in class org.springframework.integration.ftp.session.DefaultFtpsSessionFactory
- postProcessClientAfterConnect(T) - Method in class org.springframework.integration.ftp.session.AbstractFtpSessionFactory
-
Will handle additional initialization after client.connect() method was invoked, but before any action on the client has been taken.
- postProcessClientBeforeConnect(FTPSClient) - Method in class org.springframework.integration.ftp.session.DefaultFtpsSessionFactory
- postProcessClientBeforeConnect(T) - Method in class org.springframework.integration.ftp.session.AbstractFtpSessionFactory
-
Will handle additional initialization before client.connect() method was invoked.
- postProcessFilter(MessageFilter) - Method in class org.springframework.integration.config.FilterFactoryBean
- postProcessGateway(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.config.xml.AbstractOutboundGatewayParser
-
Subclasses may override this method for additional configuration.
- postProcessGateway(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.ws.config.WebServiceOutboundGatewayParser
- postProcessHeaderEnricher(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.config.xml.HeaderEnricherParserSupport
-
Subclasses may override this method to provide any additional processing.
- postProcessHeaderEnricher(BeanDefinitionBuilder, Element, ParserContext) - Method in class org.springframework.integration.config.xml.StandardHeaderEnricherParser
- PostProcessingMessageHandler - Interface in org.springframework.integration.handler
-
Implementations of this interface are subclasses of
AbstractMessageHandler
that perform post processing after theAbstractMessageHandler.handleMessageInternal(org.springframework.messaging.Message)
call. - postProcessMessage(Message<?>) - Method in class org.springframework.integration.history.HistoryWritingMessagePostProcessor
- postProcessReplyProducer(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.AbstractStandardMessageHandlerFactoryBean
- postProcessReplyProducer(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.FilterFactoryBean
- postProcessReplyProducer(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.ServiceActivatorFactoryBean
- postProcessReplyProducer(AbstractMessageProducingHandler) - Method in class org.springframework.integration.config.SplitterFactoryBean
- postProcessServerSocket(ServerSocket) - Method in class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
- postProcessServerSocket(ServerSocket) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpSocketSupport
-
No-Op.
- postProcessServerSocket(ServerSocket) - Method in interface org.springframework.integration.ip.tcp.connection.TcpSocketSupport
-
Performs any further modifications to the server socket after the connection factory has created the socket and set any configured attributes, before invoking
ServerSocket.accept()
. - postProcessSocket(Socket) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpSocketSupport
-
Enables host verification for SSL, if so configured.
- postProcessSocket(Socket) - Method in interface org.springframework.integration.ip.tcp.connection.TcpSocketSupport
-
Performs any further modifications to the
Socket
after the socket has been created by a client, or accepted by a server, and after any configured atributes have been set. - postProcessSSLEngine(SSLEngine) - Method in class org.springframework.integration.ip.tcp.connection.DefaultTcpNioSSLConnectionSupport
-
Subclasses can post-process the ssl engine (set properties).
- postProcessTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.file.config.AbstractFilePayloadTransformerParser
-
Subclasses may override this method to provide additional configuration.
- postProcessTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.file.config.FileToStringTransformerParser
- postProcessTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.zip.config.xml.AbstractZipTransformerParser
-
Subclasses may override this method to provide additional configuration.
- postProcessTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.zip.config.xml.UnZipTransformerParser
- postProcessTransformer(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.zip.config.xml.ZipTransformerParser
- postReceive(Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList
- postReceive(Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.ThreadStatePropagationChannelInterceptor
- postSend(Message<?>, MessageChannel, boolean) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList
- prefetchCount(int) - Method in class org.springframework.integration.amqp.dsl.AbstractMessageListenerContainerSpec
- prefetchCount(int) - Method in class org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec
- prefix - Variable in class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter
- prefix() - Element in annotation interface org.springframework.integration.annotation.Router
-
Specify a prefix to be added to each channel name prior to resolution.
- prefix(String) - Method in class org.springframework.integration.dsl.RouterSpec
-
Cannot be invoked if
RouterSpec.subFlowMapping(Object, IntegrationFlow)
is used. - PREFIX - Static variable in class org.springframework.integration.debezium.support.DebeziumHeaders
- PREFIX - Static variable in class org.springframework.integration.file.FileHeaders
- PREFIX - Static variable in class org.springframework.integration.http.HttpHeaders
- PREFIX - Static variable in class org.springframework.integration.jmx.JmxHeaders
- PREFIX - Static variable in class org.springframework.integration.mail.MailHeaders
- PREFIX - Static variable in class org.springframework.integration.mapping.support.JsonHeaders
- PREFIX - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders
-
A prefix for MongoDb-specific message headers.
- PREFIX - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- PREFIX - Static variable in class org.springframework.integration.redis.support.RedisHeaders
- PREFIX - Static variable in class org.springframework.integration.stomp.support.IntegrationStompHeaders
- PREFIX - Static variable in class org.springframework.integration.syslog.SyslogHeaders
- PREFIX - Static variable in class org.springframework.integration.transformer.support.AvroHeaders
-
The prefix for Apache Avro specific message headers.
- PREFIX - Static variable in class org.springframework.integration.transformer.support.ProtoHeaders
-
The prefix for Protocol Buffers specific message headers.
- PREFIX - Static variable in class org.springframework.integration.ws.WebServiceHeaders
- PREFIX - Static variable in class org.springframework.integration.xmpp.XmppHeaders
- PREFIX - Static variable in class org.springframework.integration.zeromq.ZeroMqHeaders
- PREFIX - Static variable in class org.springframework.integration.zip.ZipHeaders
- PREFIX_CHANGE_STREAM - Static variable in class org.springframework.integration.mongodb.support.MongoHeaders
-
The prefix for change stream event headers.
- PrefixBasedMatcher(boolean, String) - Constructor for class org.springframework.integration.mapping.AbstractHeaderMapper.PrefixBasedMatcher
- prepareRequest(HttpServletRequest) - Method in class org.springframework.integration.http.inbound.HttpRequestHandlingEndpointSupport
-
Prepares an instance of
ServletServerHttpRequest
from the rawHttpServletRequest
. - prepareRequestEntity(ServletServerHttpRequest) - Method in class org.springframework.integration.http.inbound.HttpRequestHandlingEndpointSupport
- preReceive(MessageChannel, Deque<ChannelInterceptor>) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList
- PresenceInboundChannelAdapterParser - Class in org.springframework.integration.xmpp.config
-
Parser for 'xmpp:presence-inbound-channel-adapter' element.
- PresenceInboundChannelAdapterParser() - Constructor for class org.springframework.integration.xmpp.config.PresenceInboundChannelAdapterParser
- PresenceListeningEndpoint - Class in org.springframework.integration.xmpp.inbound
-
An inbound endpoint that is able to login and then emit particular Presence event occurs within the logged-in user's
Roster
. - PresenceListeningEndpoint() - Constructor for class org.springframework.integration.xmpp.inbound.PresenceListeningEndpoint
- PresenceListeningEndpoint(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.inbound.PresenceListeningEndpoint
- PresenceOutboundChannelAdapterParser - Class in org.springframework.integration.xmpp.config
-
Parser for 'xmpp:presence-outbound-channel-adapter' element
- PresenceOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.xmpp.config.PresenceOutboundChannelAdapterParser
- PresenceSendingMessageHandler - Class in org.springframework.integration.xmpp.outbound
-
MessageHandler that publishes updated Presence values for a given XMPP connection.
- PresenceSendingMessageHandler() - Constructor for class org.springframework.integration.xmpp.outbound.PresenceSendingMessageHandler
- PresenceSendingMessageHandler(XMPPConnection) - Constructor for class org.springframework.integration.xmpp.outbound.PresenceSendingMessageHandler
- preSend(Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.MessageSelectingInterceptor
- preSend(Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.ThreadStatePropagationChannelInterceptor
- preSend(Message<?>, MessageChannel) - Method in class org.springframework.integration.channel.interceptor.WireTap
-
Intercept the Message and, if accepted by the
MessageSelector
, send it to the secondary target. - preSend(Message<?>, MessageChannel, Deque<ChannelInterceptor>) - Method in class org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList
- PRESERVE_TIMESTAMP - Enum constant in enum class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway.Option
-
(-P) Preserve the server timestamp (get, mget).
- preserveTimestamp(boolean) - Method in class org.springframework.integration.file.dsl.FileWritingMessageHandlerSpec
-
Set to true to preserve the destination file timestamp.
- preserveTimestamp(boolean) - Method in class org.springframework.integration.file.dsl.RemoteFileInboundChannelAdapterSpec
-
Set to true to enable the preservation of the remote file timestamp when transferring.
- preserveWireFeed(boolean) - Method in class org.springframework.integration.feed.dsl.FeedEntryMessageSourceSpec
- prev() - Method in class org.springframework.integration.syslog.RFC5424SyslogParser.Reader
- preventDuplicates(boolean) - Method in class org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec
-
Configure an
AcceptOnceFileListFilter
ifpreventDuplicates == true
, otherwise -AcceptAllFileListFilter
. - priority() - Method in class org.springframework.integration.dsl.Channels
- priority() - Static method in class org.springframework.integration.dsl.MessageChannels
- priority(int) - Method in class org.springframework.integration.jms.dsl.JmsOutboundGatewaySpec
-
Default priority.
- priority(int) - Method in class org.springframework.integration.jms.dsl.JmsPollableMessageChannelSpec
-
Default priority.
- priority(int) - Method in class org.springframework.integration.jms.dsl.JmsTemplateSpec
-
May be overridden at run time by the message priority header.
- priority(Number) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header. - priority(Number, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header. - priority(String) - Method in class org.springframework.integration.dsl.Channels
- priority(String) - Static method in class org.springframework.integration.dsl.MessageChannels
- priority(String, PriorityCapableChannelMessageStore, Object) - Method in class org.springframework.integration.dsl.Channels
- priority(String, PriorityCapableChannelMessageStore, Object) - Static method in class org.springframework.integration.dsl.MessageChannels
- priority(PriorityCapableChannelMessageStore, Object) - Method in class org.springframework.integration.dsl.Channels
- priority(PriorityCapableChannelMessageStore, Object) - Static method in class org.springframework.integration.dsl.MessageChannels
- PRIORITY - Static variable in class org.springframework.integration.IntegrationMessageHeaderAccessor
- PRIORITY - Static variable in class org.springframework.integration.mongodb.store.MessageDocumentFields
- PriorityCapableChannelMessageStore - Interface in org.springframework.integration.store
-
A
ChannelMessageStore
that supports the notion of message priority. - PriorityChannel - Class in org.springframework.integration.channel
-
A message channel that prioritizes messages based on a
Comparator
. - PriorityChannel() - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel with an unbounded queue.
- PriorityChannel(int) - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel with the specified queue capacity.
- PriorityChannel(int, Comparator<Message<?>>) - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel with the specified queue capacity.
- PriorityChannel(Comparator<Message<?>>) - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel with an unbounded queue.
- PriorityChannel(MessageGroupQueue) - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel based on the provided
MessageGroupQueue
. - PriorityChannel(PriorityCapableChannelMessageStore, Object) - Constructor for class org.springframework.integration.channel.PriorityChannel
-
Create a channel based on the provided
PriorityCapableChannelMessageStore
and group id for message store operations. - PriorityChannelSpec - Class in org.springframework.integration.dsl
- PriorityChannelSpec() - Constructor for class org.springframework.integration.dsl.PriorityChannelSpec
- priorityExpression(String) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header where the value is a SpELExpression
evaluation result. - priorityExpression(String, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header where the value is a SpELExpression
evaluation result. - priorityFunction(Function<Message<P>, ?>, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header where the value is obtained by invoking theFunction
callback. - priorityFunction(Function<Message<P>, Object>) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
-
Add a
IntegrationMessageHeaderAccessor.PRIORITY
header where the value is obtained by invoking theFunction
callback. - ProcedureParameter - Class in org.springframework.integration.jdbc.storedproc
-
Abstraction of Procedure parameters allowing to provide static parameters and SpEl Expression based parameters.
- ProcedureParameter() - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
-
Default constructor.
- ProcedureParameter(String, Object, String) - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
-
Instantiates a new Procedure Parameter.
- process(Collection<? extends Message<?>>) - Method in class org.springframework.integration.aggregator.ExpressionEvaluatingMessageListProcessor
-
Processes the Message by evaluating the expression with that Message as the root object.
- process(Collection<? extends Message<?>>) - Method in interface org.springframework.integration.aggregator.MessageListProcessor
- process(Collection<Message<?>>, Map<String, Object>) - Method in class org.springframework.integration.aggregator.MethodInvokingMessageListProcessor
- process(Collection<Message<?>>, Map<String, Object>) - Method in class org.springframework.integration.handler.support.MessagingMethodInvokerHelper
- process(Message<?>) - Method in class org.springframework.integration.handler.support.MessagingMethodInvokerHelper
- processAfterCommit(IntegrationResourceHolder) - Method in class org.springframework.integration.transaction.ExpressionEvaluatingTransactionSynchronizationProcessor
- processAfterCommit(IntegrationResourceHolder) - Method in interface org.springframework.integration.transaction.TransactionSynchronizationProcessor
- processAfterRollback(IntegrationResourceHolder) - Method in class org.springframework.integration.transaction.ExpressionEvaluatingTransactionSynchronizationProcessor
- processAfterRollback(IntegrationResourceHolder) - Method in interface org.springframework.integration.transaction.TransactionSynchronizationProcessor
- processBeanDefinition(String, AnnotatedBeanDefinition, List<Annotation>) - Method in class org.springframework.integration.config.AbstractMethodAnnotationPostProcessor
- processBeanDefinition(String, AnnotatedBeanDefinition, List<Annotation>) - Method in interface org.springframework.integration.config.annotation.MethodAnnotationPostProcessor
- processBeforeCommit(IntegrationResourceHolder) - Method in class org.springframework.integration.transaction.ExpressionEvaluatingTransactionSynchronizationProcessor
- processBeforeCommit(IntegrationResourceHolder) - Method in interface org.springframework.integration.transaction.TransactionSynchronizationProcessor
- processEvent(AbstractIMapEvent) - Method in class org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer.HazelcastEntryListener
- processEvent(E) - Method in class org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer.AbstractHazelcastEventListener
- processHeaders(Element, ManagedMap<String, Object>, ParserContext) - Method in class org.springframework.integration.config.xml.HeaderEnricherParserSupport
- processHeaders(Element, ManagedMap<String, Object>, ParserContext) - Method in class org.springframework.integration.xml.config.XPathHeaderEnricherParser
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.AbstractMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.BeanNameMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.ControlBusMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.ExpressionCommandMessageProcessor
-
Deprecated.Evaluates the Message payload expression as a command.
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.ExpressionEvaluatingMessageProcessor
-
Processes the Message by evaluating the expression with that Message as the root object.
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.LambdaMessageProcessor
- processMessage(Message<?>) - Method in interface org.springframework.integration.handler.MessageProcessor
-
Process the Message and return a value (or null).
- processMessage(Message<?>) - Method in class org.springframework.integration.handler.MethodInvokingMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.scripting.AbstractScriptExecutingMessageProcessor
-
Execute the script and return the result.
- processMessage(Message<?>) - Method in class org.springframework.integration.transformer.support.ExpressionEvaluatingHeaderValueMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.transformer.support.MessageProcessingHeaderValueMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.transformer.support.RoutingSlipHeaderValueMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.transformer.support.StaticHeaderValueMessageProcessor
- processMessage(Message<?>) - Method in class org.springframework.integration.xml.transformer.support.XPathExpressionEvaluatingHeaderValueMessageProcessor
- processMessageGroup(MessageGroup) - Method in class org.springframework.integration.aggregator.AbstractAggregatingMessageGroupProcessor
- processMessageGroup(MessageGroup) - Method in class org.springframework.integration.aggregator.DelegatingMessageGroupProcessor
- processMessageGroup(MessageGroup) - Method in interface org.springframework.integration.aggregator.MessageGroupProcessor
-
Process the given MessageGroup.
- processMessageGroup(MessageGroup) - Method in class org.springframework.integration.aggregator.ResequencingMessageGroupProcessor
- processMessageGroup(MessageGroup) - Method in class org.springframework.integration.aggregator.SimpleMessageGroupProcessor
- processMessageGroup(MessageGroup) - Method in class org.springframework.integration.file.aggregator.FileAggregator
- processNioSelections(int, Selector, ServerSocketChannel, Map<SocketChannel, TcpNioConnection>) - Method in class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
-
Times out any expired connections then, if
selectionCount > 0
, processes the selected keys. - processor(Object) - Method in class org.springframework.integration.dsl.AggregatorSpec
-
Configure the handler with
MethodInvokingCorrelationStrategy
andMethodInvokingReleaseStrategy
using the target object which should have methods annotated appropriately for each function. - processor(Object) - Method in class org.springframework.integration.dsl.CorrelationHandlerSpec
-
Configure the handler with
MethodInvokingCorrelationStrategy
andMethodInvokingReleaseStrategy
using the target object which should have methods annotated appropriately for each function. - processor(Object, String) - Method in class org.springframework.integration.dsl.AggregatorSpec
-
Configure the handler with
MethodInvokingCorrelationStrategy
andMethodInvokingReleaseStrategy
using the target object which should have methods annotated appropriately for each function. - processor(String) - Static method in class org.springframework.integration.scripting.dsl.Scripts
-
The factory method to produce
ScriptSpec
based on the script file location. - processor(Resource) - Static method in class org.springframework.integration.scripting.dsl.Scripts
-
The factory method to produce
ScriptSpec
based on theResource
. - processor(MessageProcessorSpec<?>) - Method in class org.springframework.integration.dsl.TransformerEndpointSpec
-
Provide a
MessageProcessorSpec
as a factory forMethodInvokingTransformer
delegate. - processOutboundTypeAttributes(Element, ParserContext, BeanDefinitionBuilder) - Static method in class org.springframework.integration.cassandra.config.xml.CassandraParserUtils
- processSendResult(Message<?>, ProducerRecord<K, V>, CompletableFuture<SendResult<K, V>>, MessageChannel) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
- PROCID - Static variable in class org.springframework.integration.syslog.SyslogHeaders
- produceOutput(Object, Message<?>) - Method in class org.springframework.integration.handler.AbstractMessageProducingHandler
- produceOutput(Object, Message<?>) - Method in class org.springframework.integration.splitter.AbstractMessageSplitter
- PRODUCER - Enum constant in enum class org.springframework.integration.support.management.observation.IntegrationObservation
-
Observation for message producers, e.g.
- producerListener(ProducerListener<K, V>) - Method in class org.springframework.integration.kafka.dsl.KafkaTemplateSpec
-
Set a
ProducerListener
which will be invoked when Kafka acknowledges a send operation. - producerRecordCreator(KafkaProducerMessageHandler.ProducerRecordCreator<K, V>) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
-
Set a
KafkaProducerMessageHandler.ProducerRecordCreator
to create theProducerRecord
. - produces(String...) - Method in class org.springframework.integration.http.dsl.HttpInboundEndpointSupportSpec.RequestMappingSpec
-
The producible media types of the mapped request, narrowing the primary mapping.
- producesReply(boolean) - Method in class org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
- producesReply(boolean) - Method in class org.springframework.integration.jpa.dsl.JpaUpdatingOutboundEndpointSpec
- propagation(Propagation) - Method in class org.springframework.integration.transaction.TransactionInterceptorBuilder
- PropertiesBuilder - Class in org.springframework.integration.support
-
A
Builder
pattern implementation for theProperties
. - PropertiesBuilder() - Constructor for class org.springframework.integration.support.PropertiesBuilder
- propertiesConverter(MessagePropertiesConverter) - Method in class org.springframework.integration.amqp.dsl.AmqpInboundPolledChannelAdapterSpec
- PropertiesPersistingMetadataStore - Class in org.springframework.integration.metadata
-
Properties file-based implementation of
MetadataStore
. - PropertiesPersistingMetadataStore() - Constructor for class org.springframework.integration.metadata.PropertiesPersistingMetadataStore
- property(String, Object) - Method in class org.springframework.integration.dsl.EnricherSpec
- propertyExpression(String, String) - Method in class org.springframework.integration.dsl.EnricherSpec
- propertyExpressions - Variable in class org.springframework.integration.dsl.EnricherSpec
- propertyFunction(String, Function<Message<P>, Object>) - Method in class org.springframework.integration.dsl.EnricherSpec
- protocol() - Method in class org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer
-
Return the protocol this synchronizer works with.
- protocol() - Method in class org.springframework.integration.ftp.inbound.FtpInboundFileSynchronizer
- protocol() - Method in class org.springframework.integration.sftp.inbound.SftpInboundFileSynchronizer
- protocol() - Method in class org.springframework.integration.smb.inbound.SmbInboundFileSynchronizer
- protocol(String) - Method in class org.springframework.integration.mail.dsl.MailSendingMessageHandlerSpec
-
Set the protocol.
- PROTOCOL - Static variable in class org.springframework.integration.mail.Pop3MailReceiver
- ProtoHeaders - Class in org.springframework.integration.transformer.support
-
Pre-defined names and prefixes for Protocol Buffers related headers.
- proxyDefaultMethods() - Element in annotation interface org.springframework.integration.annotation.MessagingGateway
-
Indicate if
default
methods on the interface should be proxied as well. - proxyDefaultMethods(boolean) - Method in class org.springframework.integration.dsl.GatewayProxySpec
-
Indicate if
default
methods on the interface should be proxied as well. - proxyTargetClass() - Element in annotation interface org.springframework.integration.config.EnablePublisher
-
Indicate whether subclass-based (CGLIB) proxies are to be created as opposed to standard Java interface-based proxies.
- PseudoTransactionManager - Class in org.springframework.integration.transaction
-
An implementation of
PlatformTransactionManager
that provides transaction-like semantics toMessageSource
s that are not inherently transactional. - PseudoTransactionManager() - Constructor for class org.springframework.integration.transaction.PseudoTransactionManager
- PUB_SUB_LOCK - Enum constant in enum class org.springframework.integration.redis.util.RedisLockRegistry.RedisLockType
-
The lock is acquired by redis pub-sub subscription.
- publish(String) - Method in class org.springframework.integration.file.tail.FileTailingMessageProducerSupport
- publish(String, Object, Message<?>) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- publish(String, Object, Message<?>) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- publish(String, Object, Message<?>) - Method in class org.springframework.integration.mqtt.outbound.Mqttv5PahoMessageHandler
- publish(Throwable, AttributeAccessor) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Publish an error message for the supplied throwable and context.
- publish(Message<?>, Throwable) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Publish an error message for the supplied message and throwable.
- publish(Message<?>, Message<?>, Throwable) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Publish an error message for the supplied message and throwable.
- publish(Message<?>, MessagingException) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Publish an error message for the supplied exception.
- publish(MessagingException) - Method in class org.springframework.integration.core.ErrorMessagePublisher
-
Publish an error message for the supplied exception.
- publish_subscribe_channel - Enum constant in enum class org.springframework.integration.IntegrationPatternType
- publishConnectionCloseEvent() - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
- publishConnectionExceptionEvent(Throwable) - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
- publishConnectionOpenEvent() - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
- Publisher - Annotation Interface in org.springframework.integration.annotation
-
Annotation to indicate that a method, or all public methods if applied at class-level, should publish Messages.
- PUBLISHER_ANNOTATION_POSTPROCESSOR_NAME - Static variable in class org.springframework.integration.context.IntegrationContextUtils
- PublisherAnnotationAdvisor - Class in org.springframework.integration.aop
-
An advisor that will apply the
MessagePublishingInterceptor
to any methods containing the provided annotations. - PublisherAnnotationAdvisor() - Constructor for class org.springframework.integration.aop.PublisherAnnotationAdvisor
- PublisherAnnotationAdvisor(Class<? extends Annotation>...) - Constructor for class org.springframework.integration.aop.PublisherAnnotationAdvisor
- PublisherAnnotationBeanPostProcessor - Class in org.springframework.integration.aop
-
Post-processes beans that contain the method-level @
Publisher
annotation. - PublisherAnnotationBeanPostProcessor() - Constructor for class org.springframework.integration.aop.PublisherAnnotationBeanPostProcessor
- PublisherDelegate() - Constructor for class org.springframework.integration.jmx.NotificationPublishingMessageHandler.PublisherDelegate
- publisherElementType(Class<?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
-
Configure a type for a request
Publisher
elements. - publisherElementType(Class<?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
-
Configure a type for a request
Publisher
elements. - publisherElementType(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
-
Configure a SpEL expression to evaluate a request
Publisher
elements type at runtime against a request message. - publisherElementType(Function<Message<P>, ?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
-
Configure a
Function
to evaluate a requestPublisher
elements type at runtime against a request message. - publisherElementType(ParameterizedTypeReference<?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
-
Configure a
ParameterizedTypeReference
for a requestPublisher
elements. - publisherElementType(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
-
Configure a SpEL expression to evaluate a request
Publisher
elements type at runtime against a request message. - publisherElementTypeExpression(Expression) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
-
Configure a SpEL expression to evaluate a request
Publisher
elements type at runtime against a request message. - publisherElementTypeFunction(Function<Message<P>, ?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
-
Configure a
Function
to evaluate a requestPublisher
elements type at runtime against a request message. - PublisherRegistrar - Class in org.springframework.integration.config
- PublisherRegistrar() - Constructor for class org.springframework.integration.config.PublisherRegistrar
- publishEvent(Exception, byte[], int) - Method in class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
- publishEvent(TcpConnectionEvent) - Method in class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
-
Allow interceptors etc to publish events, perhaps subclasses of TcpConnectionEvent.
- PUBLISHING_TIME - Static variable in class org.springframework.integration.hazelcast.HazelcastHeaders
-
The publishing time header name.
- PublishingInterceptorParser - Class in org.springframework.integration.config.xml
-
Parser for the <publishing-interceptor> element.
- PublishingInterceptorParser() - Constructor for class org.springframework.integration.config.xml.PublishingInterceptorParser
- publishOnFailedToAcquire(Object, Context, String) - Method in class org.springframework.integration.leader.event.DefaultLeaderEventPublisher
- publishOnFailedToAcquire(Object, Context, String) - Method in interface org.springframework.integration.leader.event.LeaderEventPublisher
-
Publish a failure to acquire event.
- publishOnGranted(Object, Context, String) - Method in class org.springframework.integration.leader.event.DefaultLeaderEventPublisher
- publishOnGranted(Object, Context, String) - Method in interface org.springframework.integration.leader.event.LeaderEventPublisher
-
Publish a granted event.
- publishOnRevoked(Object, Context, String) - Method in class org.springframework.integration.leader.event.DefaultLeaderEventPublisher
- publishOnRevoked(Object, Context, String) - Method in interface org.springframework.integration.leader.event.LeaderEventPublisher
-
Publish a revoked event.
- publishServerExceptionEvent(Exception) - Method in class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
- publishServerListeningEvent(int) - Method in class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
- publishSubscribe() - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe() - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(boolean) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(boolean) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(String) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(String) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(String, boolean) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(String, boolean) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(String, Executor) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(String, Executor) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(String, Executor, boolean) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(String, Executor, boolean) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(Executor) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(Executor) - Static method in class org.springframework.integration.dsl.MessageChannels
- publishSubscribe(Executor, boolean) - Method in class org.springframework.integration.dsl.Channels
- publishSubscribe(Executor, boolean) - Static method in class org.springframework.integration.dsl.MessageChannels
- PublishSubscribeAmqpChannel - Class in org.springframework.integration.amqp.channel
-
The
AbstractSubscribableAmqpChannel
extension for pub-sub semantics based on theFanoutExchange
. - PublishSubscribeAmqpChannel(String, AbstractMessageListenerContainer, AmqpTemplate) - Constructor for class org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel
-
Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.
- PublishSubscribeAmqpChannel(String, AbstractMessageListenerContainer, AmqpTemplate, AmqpHeaderMapper, AmqpHeaderMapper) - Constructor for class org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel
-
Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.
- publishSubscribeChannel(ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
-
The factory to produce a
JmsPublishSubscribeMessageChannelSpec
. - publishSubscribeChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
-
The factory to produce a
JmsPublishSubscribeMessageChannelSpec
. - publishSubscribeChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp
-
Create an initial AmqpPublishSubscribeMessageChannelSpec.
- publishSubscribeChannel(Executor, Consumer<PublishSubscribeSpec>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
-
The
PublishSubscribeChannel
BaseIntegrationFlowDefinition.channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. - publishSubscribeChannel(Consumer<PublishSubscribeSpec>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
-
The
PublishSubscribeChannel
BaseIntegrationFlowDefinition.channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. - publishSubscribeChannel(ConnectionFactory) - Static method in class org.springframework.integration.amqp.dsl.Amqp
-
Create an initial AmqpPublishSubscribeMessageChannelSpec.
- publishSubscribeChannel(BroadcastCapableChannel, Consumer<BroadcastPublishSubscribeSpec>) - Method in class org.springframework.integration.dsl.BaseIntegrationFlowDefinition
-
The
BroadcastCapableChannel
BaseIntegrationFlowDefinition.channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. - publishSubscribeChannel(KafkaTemplate<?, ?>, KafkaListenerContainerFactory<?>, String) - Static method in class org.springframework.integration.kafka.dsl.Kafka
-
Create a spec for a publish-subscribe channel with the provided parameters.
- PublishSubscribeChannel - Class in org.springframework.integration.channel
-
A channel that sends Messages to each of its subscribers.
- PublishSubscribeChannel() - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
-
Create a PublishSubscribeChannel that will invoke the handlers in the message sender's thread.
- PublishSubscribeChannel(boolean) - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
-
Create a PublishSubscribeChannel that will invoke the handlers in the message sender's thread considering the provided
requireSubscribers
flag. - PublishSubscribeChannel(Executor) - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
-
Create a PublishSubscribeChannel that will use an
Executor
to invoke the handlers. - PublishSubscribeChannel(Executor, boolean) - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
-
Create a PublishSubscribeChannel that will use an
Executor
to invoke the handlers. - PublishSubscribeChannelParser - Class in org.springframework.integration.config.xml
-
Parser for the <publish-subscribe-channel> element.
- PublishSubscribeChannelParser() - Constructor for class org.springframework.integration.config.xml.PublishSubscribeChannelParser
- PublishSubscribeChannelSpec<S extends PublishSubscribeChannelSpec<S>> - Class in org.springframework.integration.dsl
- PublishSubscribeChannelSpec() - Constructor for class org.springframework.integration.dsl.PublishSubscribeChannelSpec
- PublishSubscribeChannelSpec(boolean) - Constructor for class org.springframework.integration.dsl.PublishSubscribeChannelSpec
- PublishSubscribeChannelSpec(Executor) - Constructor for class org.springframework.integration.dsl.PublishSubscribeChannelSpec
- PublishSubscribeChannelSpec(Executor, boolean) - Constructor for class org.springframework.integration.dsl.PublishSubscribeChannelSpec
- PublishSubscribeKafkaChannel - Class in org.springframework.integration.kafka.channel
-
Publish/subscribe channel backed by an Apache Kafka topic.
- PublishSubscribeKafkaChannel(KafkaOperations<?, ?>, KafkaListenerContainerFactory<?>, String) - Constructor for class org.springframework.integration.kafka.channel.PublishSubscribeKafkaChannel
-
Construct an instance with the provided parameters.
- PublishSubscribeSpec - Class in org.springframework.integration.dsl
-
The
PublishSubscribeChannelSpec
extension to configure as a general flow callback for sub-flows as subscribers. - PublishSubscribeSpec() - Constructor for class org.springframework.integration.dsl.PublishSubscribeSpec
- PublishSubscribeSpec(Executor) - Constructor for class org.springframework.integration.dsl.PublishSubscribeSpec
- pubSubDomain(boolean) - Method in class org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec
-
A
pubSubDomain
flag. - pubSubNoLocal(boolean) - Method in class org.springframework.integration.jms.dsl.JmsPublishSubscribeMessageChannelSpec
-
Only applies if the
JmsMessageChannelSpec.containerType(Class)
is aDefaultMessageListenerContainer
or aSimpleMessageListenerContainer
. - pubSubZeroMqChannel(ZContext) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqChannelSpec
in pub/sub mode based on the providedZContext
. - PULL_PUSH - Enum constant in enum class org.springframework.integration.zeromq.ZeroMqProxy.Type
- purge() - Method in class org.springframework.integration.channel.ChannelPurger
- purge(MessageSelector) - Method in class org.springframework.integration.channel.QueueChannel
- purge(MessageSelector) - Method in interface org.springframework.integration.channel.QueueChannelOperations
-
Remove any
Messages
that are not accepted by the provided selector. - purgeDots(List<F>) - Method in class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway
- purgeLinks(List<F>) - Method in class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway
- purgeOrphanedGroups() - Method in class org.springframework.integration.aggregator.AbstractCorrelatingMessageHandler
-
Perform a
MessageGroupStore.expireMessageGroups(long)
with the providedAbstractCorrelatingMessageHandler.expireTimeout
. - purgeUnwantedElements(F[], Predicate<? extends F>, Comparator<? extends F>) - Static method in class org.springframework.integration.file.support.FileUtils
-
Remove entries from the array if the predicate returns true for an element.
- pushSequenceDetails(Object, int, int) - Method in class org.springframework.integration.support.AbstractIntegrationMessageBuilder
- pushSequenceDetails(Object, int, int) - Method in class org.springframework.integration.support.BaseMessageBuilder
- put(Object, Object) - Method in class org.springframework.integration.support.PropertiesBuilder
- put(String, Object) - Method in class org.springframework.integration.expression.ExpressionEvalMap
- put(String, Object) - Method in class org.springframework.integration.support.MutableMessageHeaders
- put(String, String) - Method in class org.springframework.integration.hazelcast.metadata.HazelcastMetadataStore
- put(String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
- put(String, String) - Method in interface org.springframework.integration.metadata.MetadataStore
-
Writes a key value pair to this MetadataStore.
- put(String, String) - Method in class org.springframework.integration.metadata.PropertiesPersistingMetadataStore
- put(String, String) - Method in class org.springframework.integration.metadata.SimpleMetadataStore
- put(String, String) - Method in class org.springframework.integration.mongodb.metadata.MongoDbMetadataStore
-
Store a metadata
value
under providedkey
to the configuredMongoDbMetadataStore.collectionName
. - put(String, String) - Method in class org.springframework.integration.redis.metadata.RedisMetadataStore
-
Persists the provided key and value to Redis.
- put(String, String) - Method in class org.springframework.integration.zookeeper.metadata.ZookeeperMetadataStore
- put(K, V) - Method in class org.springframework.integration.support.MapBuilder
- put(Message<?>) - Method in class org.springframework.integration.store.MessageGroupQueue
- put(Message<?>, Session<F>, String) - Method in class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway
-
Put the file based on the message to the remote server.
- put(Message<?>, Session<FTPFile>, String) - Method in class org.springframework.integration.ftp.gateway.FtpOutboundGateway
- PUT - Enum constant in enum class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway.Command
-
(put) Put a local file to the remote system.
- putAll(Map<? extends String, ?>) - Method in class org.springframework.integration.expression.ExpressionEvalMap
- putAll(Map<? extends String, ? extends Object>) - Method in class org.springframework.integration.support.MutableMessageHeaders
- putIfAbsent(String, String) - Method in class org.springframework.integration.hazelcast.metadata.HazelcastMetadataStore
- putIfAbsent(String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
- putIfAbsent(String, String) - Method in interface org.springframework.integration.metadata.ConcurrentMetadataStore
-
Atomically insert the key into the store.
- putIfAbsent(String, String) - Method in class org.springframework.integration.metadata.PropertiesPersistingMetadataStore
- putIfAbsent(String, String) - Method in class org.springframework.integration.metadata.SimpleMetadataStore
- putIfAbsent(String, String) - Method in class org.springframework.integration.mongodb.metadata.MongoDbMetadataStore
-
If the specified key is not already associated with a value, associate it with the given value.
- putIfAbsent(String, String) - Method in class org.springframework.integration.redis.metadata.RedisMetadataStore
- putIfAbsent(String, String) - Method in class org.springframework.integration.zookeeper.metadata.ZookeeperMetadataStore
- PythonScriptExecutor - Class in org.springframework.integration.scripting.jsr223
-
Deprecated, for removal: This API element is subject to removal in a future version.
- PythonScriptExecutor() - Constructor for class org.springframework.integration.scripting.jsr223.PythonScriptExecutor
-
Deprecated.
- PythonScriptExecutor.PythonVariableParser - Class in org.springframework.integration.scripting.jsr223
-
Deprecated.
- PythonVariableParser() - Constructor for class org.springframework.integration.scripting.jsr223.PythonScriptExecutor.PythonVariableParser
-
Deprecated.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
PolyglotScriptExecutor
with apython
language argument.