Package org.springframework.integration.util
Provides core utility classes.
-
Interface Summary Interface Description CloseableIterator<E> ACloseableIterator
is intended to be used when it may hold resources (such as file or socket handles).CollectionFilter<T> Base strategy for filtering out a subset of a Collection of elements.Pool<T> Represents a pool of items.SimplePool.PoolItemCallback<T> User of the pool provide an implementation of this interface; called during various pool operations. -
Class Summary Class Description AbstractExpressionEvaluator AcceptOnceCollectionFilter<T> An implementation ofCollectionFilter
that remembers the elements passed in the previous invocation in order to avoid returning those elements more than once.AnnotatedMethodFilter 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 presentBeanFactoryTypeConverter CallerBlocksPolicy ARejectedExecutionHandler
that blocks the caller until the executor has room in its queue, or a timeout occurs (in which case aRejectedExecutionException
is thrown.ClassUtils CompositeExecutor AnExecutor
that encapsulates two underlying executors.CompoundTrigger ATrigger
that delegates theCompoundTrigger.nextExecutionTime(TriggerContext)
to one of two Triggers.DynamicPeriodicTrigger This is a dynamically changeableTrigger
.ErrorHandlingTaskExecutor ATaskExecutor
implementation that wraps an existing Executor instance in order to catch any exceptions.FixedMethodFilter 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()
.IntegrationReactiveUtils Utilities for adapting integration components to/from reactive types.JavaUtils Chained utility methods to simplify some Java repetitive code.MessagingAnnotationUtils Utility methods to support annotation processing.SimplePool<T> Implementation ofPool
supporting dynamic resizing and a variable timeout when attempting to obtain an item from the pool.StackTraceUtils Utility methods for analyzing stack traces.UniqueMethodFilter UpperBound Thin wrapper around a Semaphore that allows to create a potentially unlimited upper bound to by used in buffers of messages (e.g.UUIDConverter Utility to help generate UUID instances from generic objects.WhileLockedProcessor A simple strategy callback class that allows you to provide a code that needs to be executed underLock
provided byLockRegistry
A typical usage would be to provide implementation ofWhileLockedProcessor.whileLocked()
method and then callWhileLockedProcessor.doWhileLocked()
-
Exception Summary Exception Description PoolItemNotAvailableException Thrown when a pooled item could not be obtained for some reason.