Hierarchy For Package io.awspring.cloud.kinesis.integration

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient (implements software.amazon.awssdk.services.kinesis.KinesisAsyncClient)
    • io.awspring.cloud.kinesis.integration.SpringDynamoDBStreamsAdapterClient
  • java.util.EventObject (implements java.io.Serializable)
    • org.springframework.context.ApplicationEvent
      • org.springframework.integration.events.IntegrationEvent
        • io.awspring.cloud.kinesis.integration.KinesisShardEndedEvent
  • org.springframework.integration.context.IntegrationObjectSupport (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.integration.context.ComponentSourceAware, org.springframework.integration.context.ExpressionCapable, org.springframework.beans.factory.InitializingBean, org.springframework.integration.support.context.NamedComponent)
    • org.springframework.integration.endpoint.AbstractEndpoint (implements org.springframework.beans.factory.DisposableBean, org.springframework.integration.support.management.ManageableSmartLifecycle)
      • org.springframework.integration.endpoint.MessageProducerSupport (implements org.springframework.integration.support.management.IntegrationInboundManagement, org.springframework.integration.IntegrationPattern, org.springframework.integration.core.MessageProducer, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.integration.support.management.TrackableComponent)
        • io.awspring.cloud.kinesis.integration.KclMessageDrivenChannelAdapter (implements org.springframework.context.ApplicationEventPublisherAware)
        • io.awspring.cloud.kinesis.integration.KinesisMessageDrivenChannelAdapter (implements org.springframework.context.ApplicationEventPublisherAware, org.springframework.beans.factory.DisposableBean)
    • org.springframework.integration.handler.MessageHandlerSupport (implements org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.IntegrationPattern, org.springframework.integration.context.Orderable, org.springframework.integration.support.management.TrackableComponent)
      • org.springframework.integration.handler.AbstractMessageHandler (implements reactor.core.CoreSubscriber<T>, org.springframework.messaging.MessageHandler)
        • org.springframework.integration.handler.AbstractMessageProducingHandler (implements org.springframework.integration.handler.HeaderPropagationAware, org.springframework.integration.core.MessageProducer)
          • io.awspring.cloud.kinesis.integration.KinesisMessageHandler
          • io.awspring.cloud.kinesis.integration.KplMessageHandler (implements org.springframework.context.Lifecycle)
  • io.awspring.cloud.kinesis.integration.KinesisHeaders
  • io.awspring.cloud.kinesis.integration.KinesisMessageHeaderErrorMessageStrategy (implements org.springframework.integration.support.ErrorMessageStrategy)
  • io.awspring.cloud.kinesis.integration.KinesisShardOffset
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.awspring.cloud.kinesis.integration.KplBackpressureException

Interface Hierarchy

• io.awspring.cloud.kinesis.integration.Checkpointer

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.awspring.cloud.kinesis.integration.CheckpointMode
    • io.awspring.cloud.kinesis.integration.ListenerMode