Class ContextPropagatingScheduledExecutorService

java.lang.Object

io.micronaut.context.propagation.instrument.execution.ContextPropagatingExecutorService

io.micronaut.context.propagation.instrument.execution.ContextPropagatingScheduledExecutorService

All Implemented Interfaces:

io.micronaut.scheduling.instrument.InstrumentedExecutor, io.micronaut.scheduling.instrument.InstrumentedExecutorService, io.micronaut.scheduling.instrument.InstrumentedScheduledExecutorService, io.micronaut.scheduling.instrument.RunnableInstrumenter, AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

@Internal
public class ContextPropagatingScheduledExecutorService
extends ContextPropagatingExecutorService
implements io.micronaut.scheduling.instrument.InstrumentedScheduledExecutorService

Wraps ScheduledExecutorService to instrument it for propagating the PropagatedContext across threads.

Since:

4.9.0

Constructor Summary

Constructors

Constructor	Description
ContextPropagatingScheduledExecutorService(ScheduledExecutorService target)
ContextPropagatingScheduledExecutorService(ScheduledExecutorService target, @Nullable io.micronaut.core.propagation.PropagatedContext propagatedContext)

Method Summary

Modifier and Type	Method	Description
ScheduledExecutorService	getTarget()

Methods inherited from class ContextPropagatingExecutorService

instrument, instrument, isInstrumented, unwrap

Methods inherited from class Object

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

Methods inherited from interface ExecutorService

close

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedExecutor

execute

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedExecutorService

awaitTermination, instrument, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedScheduledExecutorService

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from interface io.micronaut.scheduling.instrument.RunnableInstrumenter

instrument

Constructor Details

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target)

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target,
 @Nullable io.micronaut.core.propagation.PropagatedContext propagatedContext)

Method Details

getTarget

public ScheduledExecutorService getTarget()

Specified by:

getTarget in interface io.micronaut.scheduling.instrument.InstrumentedExecutor

Specified by:

getTarget in interface io.micronaut.scheduling.instrument.InstrumentedExecutorService

Specified by:

getTarget in interface io.micronaut.scheduling.instrument.InstrumentedScheduledExecutorService

Overrides:

getTarget in class ContextPropagatingExecutorService