All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary Class Description AuthenticationMessageProducer Spring cloud data channel description for messaging output.CamelEnvironmentPostProcessor Configure which camel cluster service implementation is active from the default supported: file, zookeeper, and kubernetes.ChannelSupplier General supplier representing the acquisition of aMessageChannel
from a producer.CheckoutCompletionProducer Spring cloud data channel description for messaging output.CommonMessagingAutoConfiguration Autoconfiguration entry point for the messaging libraryCommonMessagingDefaultRepositoryAutoConfiguration CommonMessagingJpaAutoConfiguration Auto configuration entry point for jpa data tracking libraryCommonMessagingMongoAutoConfiguration Auto configuration entry point for mongo data tracking libraryCommonMessagingRepositorySupportAutoConfiguration Beans that are common to repository implementations of data-trackingCommonMessagingServiceAutoConfiguration DefaultIdempotentMessageConsumptionService Service responsible for enforcing idempotency checks on a message before executing an operation against the message.DefaultMessageLockService Service that is responsible for managing locks for the processing of aMessage
.DefaultNotificationHandler DefaultNotificationManager DefaultNotificationManager.VoidWork Perform a task without response or exception notificationDefaultNotificationStateService Default implementation ofNotificationStateService
.DefaultRetryClusterService DefaultRetryHandler DefaultSuppressNotificationAspect Handle establishment ofSuppressNotificationContext
whenSuppressNotification
annotation is detected.DurableNotificationAutoConfiguration DurableNotificationProperties Properties that control behavior of the combination of aNotificationHandler
and aRetryHandler
.EntityAwareNotificationState EntityUtils Dynamically perform operations related to repository domain classes.ErrorMessagingAutoConfiguration Autoconfiguration for common messaging error handling.ErrorMessagingAutoConfiguration.LoggingGlobalErrorConfiguration A configuration that logs global error messages to standard output.GlobalErrorChannelListener This is a marker interface for a listener that listens to the global error channel.IdempotentMessageConsumptionService Service responsible for enforcing idempotency checks on a message before executing an operation against the message.IgnoredNotificationStateRepository Identify a repository that should not be included in the operation ofNotificationHandler
andRetryHandler
.InternalPersistenceEvent Spring level event (local to the current JVM) that is fired uponTrackable
entity persistence.JpaCustomizedResourceLockRepository Specialized implementation ofJpaResourceLockRepository
.JpaResourceLock Represents a single lock on a resource held in the current datastore.JpaResourceLockRepository KafkaCommonMessagingAutoConfiguration Kafka specific messaging configuration.KafkaCommonMessagingAutoConfiguration.SpringKafkaRetryDisablingConfiguration Configuration that disables Spring Kafka retries.LockStatus Report on the status of a lock.LoggingGlobalErrorChannelListener A global error channel listener that logs the errored messages.MessageAdditionalInformationAware An entity can be wrapped with this interface before passing toDefaultNotificationHandler
for processing.MessageFactory<T> Factory for creating aMessage
to be sent viaNotificationHandler
, based on an entity.MessageLockService Service that is responsible for managing locks for the processing of aMessage
.MessageSerializationHelper Helper class for managing serialized state of message information.MessageSupplier<T> MessageUtils Utility methods useful for creating and working with messages, such as compression and decompression of large payloads.MessagingDataRouteSupporting MessagingProperties MongoCustomizedResourceLockRepository Specialized implementation ofMongoResourceLockRepository
.MongoResourceLock Represents a single lock on a resource held in the current datastore.MongoResourceLockRepository NoOpResourceLockRepository SimpleResourceLockRepository
implementation that DOES NOTHING.NotificationHandler Notify the system about a state change for aNotificationStateAware
entity.NotificationHandlerResponse Response information from aNotificationHandler#handle(NotificationStateRepository, NotificationStateAware, MessageType)
call.NotificationManager Management component for processing a state change on an object through one or more orderedNotificationHandler
instances.NotificationProperties Configuration for aNotificationHandler
NotificationState Keep track of message bus notification of state change of aNotificationStateAware
entity.NotificationStateAware A domain that keeps track ofNotificationState
NotificationStateRepository Additional interface for repository instances that are capable of interacting withNotificationState
related information onNotificationStateAware
domain.NotificationStateRepositoryFragment Marker interface used to differentiate between a full repository implementingNotificationStateRepository
and a internal repository fragment component providing the actual implementation.NotificationStateService Used to retrieve theNotificationState
from theNotificationStateAware
.PersistenceHandler PersistenceHandlers are responsible for listening forPersistenceConsumer
channel events associated with a specific repository domain type.PersistenceMessage<T> Formats the message in a way that thePersistenceConsumer
expects to receive the payload inPersistenceMessageAckedHandler Every component implementing this interface is injected and invoked byPersistenceMessageNotificationHandler.afterSuccessfulAcknowledgement(Object, NotificationStateAware, NotificationStateRepository)
following successful acknowledgement of aNotificationState
for aPersistenceMessage
.PersistenceMessageFactory MessageFactory
for creating messages suitable for thePersistenceProducer
channelPersistenceMessageNotificationHandler TheNotificationHandler
implementation specifically for sendingPersistenceMessage
viaPersistenceProducer
.PersistenceNotificationAutoConfiguration Configure the durable notification components related toPersistenceProducer
PersistenceNotificationProperties Configuration properties for theNotificationHandler
andRetryHandler
related toPersistenceProducer
PersistenceProducer Spring cloud data channel description for messaging output.PurgeLockTriggeredJobEventConsumer Spring cloud stream messaging interface for receiving triggered job execution from the scheduled job microservice.PurgeMessageLocksListener Scheduled Job listener that is responsible for initiating the purging of message locks for all relevant data routes.ResourceLockException Exception thrown when the system is unable to acquire a lock on a resource.ResourceLockProperties Configuration forResourceLockRepository
.ResourceLockRepository<D,ID> Repository responsible for allowing requesters to lock and unlock a resource.RetryBreakException Generally thrown during retry processing to allow theRetryHandler
to break out of a processing loop.RetryClusterService Used to keep track of start/stop behavior that determines node leadership in a cluster.RetryHandler Retry notification on a set schedule for unacknowledgedNotificationStateAware
instances belonging to a specificNotificationStateRepository
instance.RetryProperties Configuration for aRetryHandler
RetryServiceFactory Factory for constructing newRetryClusterService
instances.ScheduledJobDetailRef Detailed information for aScheduledJobRef
, which corresponds to a ScheduledJobDetail of the scheduled job microservice.ScheduledJobRef A reference to a ScheduledJob of the scheduled job microservice.Securable A Spring Cloud Stream message containing a JWT token that can be verified for authenticity and that contains claims about the messages originating user that can be validated for suitability of consumption in the current context.SuppressNotification Demarcate a flow during which notification viaNotificationHandler
should be suppressed for one or more message types.SuppressNotificationContext Threadlocal describing one or more message types for which notification should be suppressed during a flow.