Class Hierarchy
- java.lang.Object
- io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue<K,V> (implements io.streamthoughts.azkarra.api.events.BlockingRecordQueue<K,V>)
- io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue<K,V> (implements io.streamthoughts.azkarra.api.events.BlockingRecordQueue<K,V>)
- io.streamthoughts.azkarra.api.events.EventStream<K,V>
- io.streamthoughts.azkarra.api.events.EventStream.Builder
- io.streamthoughts.azkarra.api.events.EventStreamSupport (implements io.streamthoughts.azkarra.api.events.EventStreamProvider)
- io.streamthoughts.azkarra.api.events.LimitHandlers
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- io.streamthoughts.azkarra.api.errors.AzkarraException
- io.streamthoughts.azkarra.api.events.LimitHandler.BlockingQueueLimitReachedException
- io.streamthoughts.azkarra.api.errors.AzkarraException
- java.lang.RuntimeException
- java.lang.Exception
Interface Hierarchy
- io.streamthoughts.azkarra.api.events.BlockingRecordQueue<K,V>
- io.streamthoughts.azkarra.api.events.EventStreamPipe<K,V>
- io.streamthoughts.azkarra.api.events.EventStreamProvider
- io.streamthoughts.azkarra.api.events.LimitHandler