Package org.springframework.integration.util
package org.springframework.integration.util
Provides core utility classes.
-
ClassDescriptionAn implementation of
CollectionFilter
that remembers the elements passed in the previous invocation in order to avoid returning those elements more than once.A MethodFilter implementation that enables the following: matching on method name, if available exclusion of void-returning methods if 'requiresReply' is true limiting to annotated methods if at least one is present .ARejectedExecutionHandler
that blocks the caller until the executor has room in its queue, or a timeout occurs (in which case aRejectedExecutionException
is thrown.CheckedCallable<T,E extends Throwable> A Callable-like interface which allows throwing any Throwable.CheckedFunction<T,R, E extends Throwable> A Function-like interface which allows throwing Error.CheckedRunnable<E extends Throwable>A Runnable-like interface which allows throwing any Throwable.ACloseableIterator
is intended to be used when it may hold resources (such as file or socket handles).Base strategy for filtering out a subset of a Collection of elements.AnExecutor
that encapsulates two underlying executors.ATrigger
that delegates theTrigger.nextExecutionTime(TriggerContext)
to one of two Triggers.Additional utilities for working with Kotlin Coroutines.This is a dynamically changeableTrigger
.ATaskExecutor
implementation that wraps an existing Executor instance in order to catch any exceptions.AMethodFilter
implementation that will always return the same Method instance within a single-element list if it is present in the candidate list.FunctionIterator<T,V> AnIterator
implementation to convert each item from the targetFunctionIterator.iterator
to a new object applying theFunctionIterator.function
onFunctionIterator.next()
.Utilities for adapting integration components to/from reactive types.Utility methods to support annotation processing.Pool<T>Represents a pool of items.Thrown when a pooled item could not be obtained for some reason.SimplePool<T>Implementation ofPool
supporting dynamic resizing and a variable timeout when attempting to obtain an item from the pool.User of the pool provide an implementation of this interface; called during various pool operations.Utility methods for analyzing stack traces.Thin wrapper around a Semaphore that allows to create a potentially unlimited upper bound to by used in buffers of messages (e.g.Utility to help generate UUID instances from generic objects.Deprecated, for removal: This API element is subject to removal in a future version.
LockRegistry.executeLocked(java.lang.Object, org.springframework.integration.util.CheckedRunnable<E>)
.