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)

Method Summary

Modifier and Type	Method	Description
io.vertx.mutiny.core.Context	getContext()
void	runOnContext(Runnable runnable)

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)

Method Detail

getContext

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

runOnContext

public void runOnContext(Runnable runnable)