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 aParameterSourcethat 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 aParameterSourceFactoryto 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 theparameterTyperecord component.
- parameterTypes() - Method in record class org.springframework.integration.http.management.ControlBusController.ControlBusCommand
- 
Returns the value of theparameterTypesrecord 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 providedPropertiesand build anIntegrationPropertiesinstance.
- 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.DefaultRouterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.FilterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.ServiceActivatorParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.SplitterParser
- parseHandler(Element, ParserContext) - Method in class org.springframework.integration.config.xml.TransformerParser
- 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 Class in org.springframework.integration.support
- 
AMessagingExceptionthrown when a non-transactional operation is performing multiple updates from a single message, e.g.
- PartialSuccessException(Message<?>, String, Throwable, Collection<?>, Collection<?>) - Constructor for exception class org.springframework.integration.support.PartialSuccessException
- partitioned(int) - Method in class org.springframework.integration.dsl.Channels
- 
Create aPartitionedChannelSpec.
- partitioned(int) - Static method in class org.springframework.integration.dsl.MessageChannels
- 
Create aPartitionedChannelSpec.
- partitioned(String, int) - Method in class org.springframework.integration.dsl.Channels
- 
Create aPartitionedChannelSpec.
- partitioned(String, int) - Static method in class org.springframework.integration.dsl.MessageChannels
- 
Create aPartitionedChannelSpec.
- PartitionedChannel - Class in org.springframework.integration.channel
- 
AnAbstractExecutorChannelimplementation 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 theIntegrationMessageHeaderAccessor.CORRELATION_IDmessage 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
- 
ALoadBalancingChannelSpecimplementation for thePartitionedChannel.
- PartitionedChannelSpec(int) - Constructor for class org.springframework.integration.dsl.PartitionedChannelSpec
- PartitionedDispatcher - Class in org.springframework.integration.dispatcher
- 
AnAbstractDispatcherimplementation 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 aFunctionthat 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 anExpressionto 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 simpleTransactionSynchronizationFactoryimplementation which produces anIntegrationResourceHolderSynchronizationwith anIntegrationResourceHolder.
- PassThroughTransactionSynchronizationFactory() - Constructor for class org.springframework.integration.transaction.PassThroughTransactionSynchronizationFactory
- PassThruLockRegistry - Class in org.springframework.integration.support.locks
- 
TheLockRegistryimplementation which has no effect.
- PassThruLockRegistry() - Constructor for class org.springframework.integration.support.locks.PassThruLockRegistry
- PassThruMessageConverter - Class in org.springframework.integration.support.converter
- 
The simpleMessageConverterimplementation which contract is to returnMessageas is for bothfrom/tooperations.
- 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 theIntegrationGraphController.
- 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 aSimplePatternFileListFilter.
- 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
- 
ASimplePatternFileListFilterthat runs against the local file system view when usingMPUTcommand.
- 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 theAllowListDeserializingConverterwith 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 thepayloadfor 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 thepayloadfor 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
- 
TheHandlerMethodArgumentResolverfor evaluatingPayload.expression()as a SpEL expression againstmessageand 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 aFunctionto evaluate in order to generate the Message payload.
- payloadFunction(Function<MethodArgsHolder, ?>) - Method in class org.springframework.integration.dsl.GatewayProxySpec
- 
AFunctionthat will be used to generate thepayloadfor 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 aMessageequal 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
- 
TheHandlerMethodArgumentResolverfor resolving aCollectionofpayloadsor 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 theSerializingConverterwith 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 asStringJsonMessageConverter), 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 theMessageChannelbased on theMessage'spayload 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
- 
AMessageSelectorimplementation that checks the type of theMessagepayload.
- 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 aThrowable payloadbased on the provided context for futureErrorMessagewhen 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
- 
TheFactoryBeanto produce aPeriodicTriggerbased 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 aPersistModefor 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 aPgConnectionto a Postgres database that is to be used for aPostgresChannelMessageTableSubscriber.
- phase() - Element in annotation interface org.springframework.integration.annotation.Aggregator
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.BridgeFrom
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.BridgeTo
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.Filter
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.InboundChannelAdapter
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.Router
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.ServiceActivator
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.Splitter
- 
Specify aSmartLifecyclephaseoption.
- phase() - Element in annotation interface org.springframework.integration.annotation.Transformer
- 
Specify aSmartLifecyclephaseoption.
- 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
- 
TheAbstractSubscribableAmqpChannelimplementation 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
- 
APollableChannelimplementation 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 aRabbitTemplateand 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 aJmsPollableMessageChannelSpec.
- pollableChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
- 
The factory to produce aJmsPollableMessageChannelSpec.
- 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 thePollerMetadataoptions for the Messaging annotations for polled endpoints.
- PollerFactory - Class in org.springframework.integration.dsl
- 
AnAdapterclass for thePollersfactory.
- 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 providePollerSpecs forPollerMetadataconfiguration variants.
- PollerSpec - Class in org.springframework.integration.dsl
- 
AnIntegrationComponentSpecforPollerMetadatas.
- PollingConsumer - Class in org.springframework.integration.endpoint
- 
Message Endpoint that connects anyMessageHandlerimplementation 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 thisMessageGroup(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 PolyglotScriptExecutorimplementation.
- 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 Class in org.springframework.integration.util
- 
Thrown when a pooled item could not be obtained for some reason.
- PoolItemNotAvailableException(String) - Constructor for exception class org.springframework.integration.util.PoolItemNotAvailableException
- PoolItemNotAvailableException(String, Throwable) - Constructor for exception class 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
- 
APop3MailInboundChannelAdapterSpecfactory using a defaultPop3MailReceiver.
- pop3InboundAdapter(String) - Static method in class org.springframework.integration.mail.dsl.Mail
- 
APop3MailInboundChannelAdapterSpecfactory based on the provided url.
- pop3InboundAdapter(String, int, String, String) - Static method in class org.springframework.integration.mail.dsl.Mail
- 
APop3MailInboundChannelAdapterSpecfactory based on the provided host, port, user, and password.
- pop3InboundAdapter(String, String, String) - Static method in class org.springframework.integration.mail.dsl.Mail
- 
APop3MailInboundChannelAdapterSpecfactory based on the provided host, user, password and the default port.
- pop3InboundAdapter(Pop3MailReceiver) - Static method in class org.springframework.integration.mail.dsl.Mail
- 
APop3MailInboundChannelAdapterSpecfactory based on the providedPop3MailReceiver.
- Pop3MailInboundChannelAdapterSpec - Class in org.springframework.integration.mail.dsl
- 
AMailInboundChannelAdapterSpecfor 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
- 
AMailReceiverimplementation 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 aBaseMessageBuilder.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 aJdbcChannelMessageStore.
- PostgresChannelMessageTableSubscriber(PgConnectionSupplier) - Constructor for class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
- 
Create a new subscriber using theJdbcChannelMessageStore.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 aPostgresChannelMessageTableSubscriberfor receiving push notifications for new messages that are added to aJdbcChannelMessageStore.
- PostgresSubscribableChannel - Class in org.springframework.integration.jdbc.channel
- 
AnAbstractSubscribableChannelfor 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 ofAbstractMessageHandlerthat 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 invokingServerSocket.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 theSocketafter 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 ifRouterSpec.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 ofServletServerHttpRequestfrom 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'sRoster.
- 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 theMessageSelector, 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 anAcceptOnceFileListFilterifpreventDuplicates == 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 aIntegrationMessageHeaderAccessor.PRIORITYheader.
- priority(Number, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
- 
Add aIntegrationMessageHeaderAccessor.PRIORITYheader.
- 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
- 
AChannelMessageStorethat supports the notion of message priority.
- PriorityChannel - Class in org.springframework.integration.channel
- 
A message channel that prioritizes messages based on aComparator.
- 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 providedMessageGroupQueue.
- PriorityChannel(PriorityCapableChannelMessageStore, Object) - Constructor for class org.springframework.integration.channel.PriorityChannel
- 
Create a channel based on the providedPriorityCapableChannelMessageStoreand 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 aIntegrationMessageHeaderAccessor.PRIORITYheader where the value is a SpELExpressionevaluation result.
- priorityExpression(String, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
- 
Add aIntegrationMessageHeaderAccessor.PRIORITYheader where the value is a SpELExpressionevaluation result.
- priorityFunction(Function<Message<P>, ?>, Boolean) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
- 
Add aIntegrationMessageHeaderAccessor.PRIORITYheader where the value is obtained by invoking theFunctioncallback.
- priorityFunction(Function<Message<P>, Object>) - Method in class org.springframework.integration.dsl.HeaderEnricherSpec
- 
Add aIntegrationMessageHeaderAccessor.PRIORITYheader where the value is obtained by invoking theFunctioncallback.
- 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, ifselectionCount > 0, processes the selected keys.
- processor(Object) - Method in class org.springframework.integration.dsl.AggregatorSpec
- 
Configure the handler withMethodInvokingCorrelationStrategyandMethodInvokingReleaseStrategyusing 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 withMethodInvokingCorrelationStrategyandMethodInvokingReleaseStrategyusing 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 withMethodInvokingCorrelationStrategyandMethodInvokingReleaseStrategyusing 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 produceScriptSpecbased on the script file location.
- processor(Resource) - Static method in class org.springframework.integration.scripting.dsl.Scripts
- 
The factory method to produceScriptSpecbased on theResource.
- processor(MessageProcessorSpec<?>) - Method in class org.springframework.integration.dsl.TransformerEndpointSpec
- 
Provide aMessageProcessorSpecas a factory forMethodInvokingTransformerdelegate.
- 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 aProducerListenerwhich will be invoked when Kafka acknowledges a send operation.
- producerRecordCreator(KafkaProducerMessageHandler.ProducerRecordCreator<K, V>) - Method in class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
- 
Set aKafkaProducerMessageHandler.ProducerRecordCreatorto 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
- 
ABuilderpattern 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 ofMetadataStore.
- 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 ifdefaultmethods on the interface should be proxied as well.
- proxyDefaultMethods(boolean) - Method in class org.springframework.integration.dsl.GatewayProxySpec
- 
Indicate ifdefaultmethods 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 ofPlatformTransactionManagerthat provides transaction-like semantics toMessageSources 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 theMessagePublishingInterceptorto 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 @Publisherannotation.
- 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 requestPublisherelements.
- publisherElementType(Class<?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
- 
Configure a type for a requestPublisherelements.
- publisherElementType(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
- 
Configure a SpEL expression to evaluate a requestPublisherelements type at runtime against a request message.
- publisherElementType(Function<Message<P>, ?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
- 
Configure aFunctionto evaluate a requestPublisherelements type at runtime against a request message.
- publisherElementType(ParameterizedTypeReference<?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
- 
Configure aParameterizedTypeReferencefor a requestPublisherelements.
- publisherElementType(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
- 
Configure a SpEL expression to evaluate a requestPublisherelements 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 requestPublisherelements type at runtime against a request message.
- publisherElementTypeFunction(Function<Message<P>, ?>) - Method in class org.springframework.integration.webflux.dsl.WebFluxMessageHandlerSpec
- 
Configure aFunctionto evaluate a requestPublisherelements 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
- 
TheAbstractSubscribableAmqpChannelextension 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 aJmsPublishSubscribeMessageChannelSpec.
- publishSubscribeChannel(String, ConnectionFactory) - Static method in class org.springframework.integration.jms.dsl.Jms
- 
The factory to produce aJmsPublishSubscribeMessageChannelSpec.
- 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
- 
ThePublishSubscribeChannelBaseIntegrationFlowDefinition.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
- 
ThePublishSubscribeChannelBaseIntegrationFlowDefinition.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
- 
TheBroadcastCapableChannelBaseIntegrationFlowDefinition.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 providedrequireSubscribersflag.
- PublishSubscribeChannel(Executor) - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
- 
Create a PublishSubscribeChannel that will use anExecutorto invoke the handlers.
- PublishSubscribeChannel(Executor, boolean) - Constructor for class org.springframework.integration.channel.PublishSubscribeChannel
- 
Create a PublishSubscribeChannel that will use anExecutorto 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> - 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
- 
ThePublishSubscribeChannelSpecextension 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
- 
ApubSubDomainflag.
- pubSubNoLocal(boolean) - Method in class org.springframework.integration.jms.dsl.JmsPublishSubscribeMessageChannelSpec
- 
Only applies if theJmsMessageChannelSpec.containerType(Class)is aDefaultMessageListenerContaineror aSimpleMessageListenerContainer.
- pubSubZeroMqChannel(ZContext) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
- 
Create an instance ofZeroMqChannelSpecin 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 anyMessagesthat 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 aMessageGroupStore.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 metadatavalueunder providedkeyto 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
PolyglotScriptExecutorwith apythonlanguage argument.