Index

A C D E G H I J L M O P R S T V W
All Classes and Interfaces|All Packages|Serialized Form

A

accepts(Class<?>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JaxbSerialization

accepts(Class<?>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JsonbSerialization

accepts(Class<?>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.SerializableSerialization

addEvent(PendingEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.store.EventsPublished

C

cancel() - Method in interface com.github.jonasrutishauser.transactional.event.core.concurrent.EventExecutor.Task

com.github.jonasrutishauser.transactional.event.core - package com.github.jonasrutishauser.transactional.event.core

com.github.jonasrutishauser.transactional.event.core.cdi - package com.github.jonasrutishauser.transactional.event.core.cdi

com.github.jonasrutishauser.transactional.event.core.concurrent - package com.github.jonasrutishauser.transactional.event.core.concurrent

com.github.jonasrutishauser.transactional.event.core.defaults - package com.github.jonasrutishauser.transactional.event.core.defaults

com.github.jonasrutishauser.transactional.event.core.handler - package com.github.jonasrutishauser.transactional.event.core.handler

com.github.jonasrutishauser.transactional.event.core.metrics - package com.github.jonasrutishauser.transactional.event.core.metrics

com.github.jonasrutishauser.transactional.event.core.opentelemetry - package com.github.jonasrutishauser.transactional.event.core.opentelemetry

com.github.jonasrutishauser.transactional.event.core.random - package com.github.jonasrutishauser.transactional.event.core.random

com.github.jonasrutishauser.transactional.event.core.serialization - package com.github.jonasrutishauser.transactional.event.core.serialization

com.github.jonasrutishauser.transactional.event.core.store - package com.github.jonasrutishauser.transactional.event.core.store

createDefaultEventDeserializer(Instance<GenericSerialization>, Class<T>) - Static method in class com.github.jonasrutishauser.transactional.event.core.cdi.EventHandlerExtension

D

DEFAULT - Static variable in interface com.github.jonasrutishauser.transactional.event.core.concurrent.DefaultEventExecutor.InContextWrapper

DefaultConcurrencyProvider - Class in com.github.jonasrutishauser.transactional.event.core.defaults

DefaultConcurrencyProvider() - Constructor for class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultConcurrencyProvider

DefaultEventDeserializer<T> - Class in com.github.jonasrutishauser.transactional.event.core.cdi

DefaultEventDeserializer(Class<T>, GenericSerialization) - Constructor for class com.github.jonasrutishauser.transactional.event.core.cdi.DefaultEventDeserializer

DefaultEventExecutor - Class in com.github.jonasrutishauser.transactional.event.core.concurrent

DefaultEventExecutor.InContextWrapper - Interface in com.github.jonasrutishauser.transactional.event.core.concurrent

DefaultEventSerializer - Class in com.github.jonasrutishauser.transactional.event.core.serialization

DefaultEventTypeResolver - Class in com.github.jonasrutishauser.transactional.event.core.defaults

DefaultEventTypeResolver() - Constructor for class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultEventTypeResolver

DefaultProcessingStrategy - Class in com.github.jonasrutishauser.transactional.event.core.defaults

DefaultProcessingStrategy() - Constructor for class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultProcessingStrategy

deserialize(String) - Method in class com.github.jonasrutishauser.transactional.event.core.cdi.DefaultEventDeserializer

deserialize(String, Class<T>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JaxbSerialization

deserialize(String, Class<T>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JsonbSerialization

deserialize(String, Class<T>) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.SerializableSerialization

Dispatcher - Interface in com.github.jonasrutishauser.transactional.event.core.store

dispatchInterval() - Method in interface com.github.jonasrutishauser.transactional.event.core.store.Dispatcher

E

EventExecutor - Interface in com.github.jonasrutishauser.transactional.event.core.concurrent

EventExecutor.Task - Interface in com.github.jonasrutishauser.transactional.event.core.concurrent

EventHandlerExtension - Class in com.github.jonasrutishauser.transactional.event.core.cdi

EventHandlerExtension() - Constructor for class com.github.jonasrutishauser.transactional.event.core.cdi.EventHandlerExtension

EventHandlerLiteral - Class in com.github.jonasrutishauser.transactional.event.core.cdi

EventHandlers - Interface in com.github.jonasrutishauser.transactional.event.core.handler

EventsPublished - Class in com.github.jonasrutishauser.transactional.event.core.store

EventsPublished() - Constructor for class com.github.jonasrutishauser.transactional.event.core.store.EventsPublished

eventType() - Method in class com.github.jonasrutishauser.transactional.event.core.cdi.EventHandlerLiteral

execute(Runnable) - Method in class com.github.jonasrutishauser.transactional.event.core.concurrent.DefaultEventExecutor

ExtendedEventDeserializer<T> - Interface in com.github.jonasrutishauser.transactional.event.core.cdi

G

get(String) - Method in class com.github.jonasrutishauser.transactional.event.core.opentelemetry.InstrumentedWorkProcessor

get(String) - Method in interface com.github.jonasrutishauser.transactional.event.core.store.WorkProcessor

getContext() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getDelayedUntil() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getHandlerQualifier(EventTypeResolver, String) - Method in class com.github.jonasrutishauser.transactional.event.core.cdi.EventHandlerExtension

getHandlerQualifier(EventTypeResolver, String) - Method in interface com.github.jonasrutishauser.transactional.event.core.handler.EventHandlers

getId() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getPayload() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getPublishedAt() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getTries() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

getType() - Method in class com.github.jonasrutishauser.transactional.event.core.PendingEvent

H

handle(String) - Method in class com.github.jonasrutishauser.transactional.event.core.cdi.SyntheticHandler

I

init(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

InstrumentedDispatcher - Class in com.github.jonasrutishauser.transactional.event.core.opentelemetry

InstrumentedProcessor - Class in com.github.jonasrutishauser.transactional.event.core.opentelemetry

InstrumentedPublisher - Class in com.github.jonasrutishauser.transactional.event.core.opentelemetry

InstrumentedWorkProcessor - Class in com.github.jonasrutishauser.transactional.event.core.opentelemetry

J

JaxbSerialization - Class in com.github.jonasrutishauser.transactional.event.core.serialization

JaxbSerialization() - Constructor for class com.github.jonasrutishauser.transactional.event.core.serialization.JaxbSerialization

JsonbSerialization - Class in com.github.jonasrutishauser.transactional.event.core.serialization

JsonbSerialization(JsonbConfig) - Constructor for class com.github.jonasrutishauser.transactional.event.core.serialization.JsonbSerialization

L

Literal(Class<?>) - Constructor for class com.github.jonasrutishauser.transactional.event.core.cdi.TypedEventHandler.Literal

M

maxTries() - Method in class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultProcessingStrategy

MetricsEventObserver - Class in com.github.jonasrutishauser.transactional.event.core.metrics

MetricsEventObserver() - Constructor for class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

O

of(Class<?>) - Static method in class com.github.jonasrutishauser.transactional.event.core.cdi.TypedEventHandler.Literal

of(String) - Static method in class com.github.jonasrutishauser.transactional.event.core.cdi.EventHandlerLiteral

P

PendingEvent - Class in com.github.jonasrutishauser.transactional.event.core

PendingEvent(String, String, String, String, LocalDateTime, Instant) - Constructor for class com.github.jonasrutishauser.transactional.event.core.PendingEvent

PendingEvent(String, String, String, String, LocalDateTime, Instant, int) - Constructor for class com.github.jonasrutishauser.transactional.event.core.PendingEvent

process(String, String, Properties, String, Handler) - Method in class com.github.jonasrutishauser.transactional.event.core.opentelemetry.InstrumentedProcessor

processAttemptFailed(ProcessingFailedEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

processBlocked(ProcessingBlockedEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

processDeleted(ProcessingDeletedEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

processDirect(EventsPublished) - Method in class com.github.jonasrutishauser.transactional.event.core.opentelemetry.InstrumentedDispatcher

processDirect(EventsPublished) - Method in interface com.github.jonasrutishauser.transactional.event.core.store.Dispatcher

processingLockDuration() - Method in class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultProcessingStrategy

processSuccess(ProcessingSuccessEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

processUnblocked(ProcessingUnblockedEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

publish(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.TransactionalEventPublisher

publish(String, String, Properties, String) - Method in class com.github.jonasrutishauser.transactional.event.core.opentelemetry.InstrumentedPublisher

publishDelayed(Object, TemporalAmount) - Method in class com.github.jonasrutishauser.transactional.event.core.TransactionalEventPublisher

published(PublishingEvent) - Method in class com.github.jonasrutishauser.transactional.event.core.metrics.MetricsEventObserver

R

Random - Class in com.github.jonasrutishauser.transactional.event.core.random

randomId() - Static method in class com.github.jonasrutishauser.transactional.event.core.random.Random

resolve(Class<?>) - Method in class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultEventTypeResolver

S

schedule() - Method in class com.github.jonasrutishauser.transactional.event.core.opentelemetry.InstrumentedDispatcher

schedule() - Method in interface com.github.jonasrutishauser.transactional.event.core.store.Dispatcher

schedule(Runnable, LongSupplier) - Method in class com.github.jonasrutishauser.transactional.event.core.concurrent.DefaultEventExecutor

schedule(Runnable, LongSupplier) - Method in interface com.github.jonasrutishauser.transactional.event.core.concurrent.EventExecutor

SerializableSerialization - Class in com.github.jonasrutishauser.transactional.event.core.serialization

SerializableSerialization() - Constructor for class com.github.jonasrutishauser.transactional.event.core.serialization.SerializableSerialization

serialize(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.DefaultEventSerializer

serialize(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JaxbSerialization

serialize(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.JsonbSerialization

serialize(Object) - Method in class com.github.jonasrutishauser.transactional.event.core.serialization.SerializableSerialization

Startup - Interface in com.github.jonasrutishauser.transactional.event.core.cdi

SyntheticHandler<T> - Class in com.github.jonasrutishauser.transactional.event.core.cdi

SyntheticHandler(EventDeserializer<T>, Invoker<?, ?>) - Constructor for class com.github.jonasrutishauser.transactional.event.core.cdi.SyntheticHandler

T

TransactionalEventPublisher - Class in com.github.jonasrutishauser.transactional.event.core

TypedEventHandler - Annotation Type in com.github.jonasrutishauser.transactional.event.core.cdi

TypedEventHandler.Literal - Class in com.github.jonasrutishauser.transactional.event.core.cdi

V

value() - Method in class com.github.jonasrutishauser.transactional.event.core.cdi.TypedEventHandler.Literal

value() - Element in annotation type com.github.jonasrutishauser.transactional.event.core.cdi.TypedEventHandler

W

waitDurationForRetry(int) - Method in class com.github.jonasrutishauser.transactional.event.core.defaults.DefaultProcessingStrategy

WorkProcessor - Interface in com.github.jonasrutishauser.transactional.event.core.store

A C D E G H I J L M O P R S T V W
All Classes and Interfaces|All Packages|Serialized Form