Package io.smallrye.reactive.messaging.kafka.commit

Class ContextHolder

java.lang.Object

io.smallrye.reactive.messaging.kafka.commit.ContextHolder

Direct Known Subclasses:

KafkaLatestCommit, KafkaThrottledLatestProcessedCommit

public class ContextHolder
extends Object

A class holding a vert.x context to make sure methods are always run from the same one.

Field Summary

Fields

Modifier and Type	Field	Description
protected io.vertx.mutiny.core.Context	context
protected io.vertx.mutiny.core.Vertx	vertx

Constructor Summary

Constructors

Constructor	Description
ContextHolder(io.vertx.mutiny.core.Vertx vertx, int defaultTimeout)

Method Summary

Modifier and Type	Method	Description
void	capture(io.vertx.kafka.client.consumer.KafkaReadStream<?,?> stream)
io.vertx.mutiny.core.Context	getContext()
void	runOnContext(Runnable runnable)
<T> T	runOnContextAndAwait(Callable<T> action)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

vertx

protected final io.vertx.mutiny.core.Vertx vertx

context

protected volatile io.vertx.mutiny.core.Context context

Constructor Detail

ContextHolder

public ContextHolder(io.vertx.mutiny.core.Vertx vertx,
                     int defaultTimeout)

Method Detail

capture

public void capture(io.vertx.kafka.client.consumer.KafkaReadStream<?,?> stream)

getContext

public io.vertx.mutiny.core.Context getContext()

runOnContext

public void runOnContext(Runnable runnable)

runOnContextAndAwait

public <T> T runOnContextAndAwait(Callable<T> action)