Package io.awspring.cloud.sqs.support.observation

Class MessageHeaderContextAccessor

java.lang.Object

io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor

All Implemented Interfaces:

io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

public class MessageHeaderContextAccessor
extends Object
implements io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

ContextAccessor that use MessageHeaders to hold the Observation context. Intended for read-only operations.

Since:

3.4

Author:

Tomaz Fernandes

Constructor Summary

Constructors

Constructor	Description
MessageHeaderContextAccessor()

Method Summary

Modifier and Type	Method	Description
Class<? extends MessageHeaders>	readableType()
<T> T	readValue(MessageHeaders sourceContext, Object key)
void	readValues(MessageHeaders sourceContext, Predicate<Object> keyPredicate, Map<Object,Object> target)
Class<? extends MessageHeaders>	writeableType()
MessageHeaders	writeValues(Map<Object,Object> valuesToWrite, MessageHeaders targetContext)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageHeaderContextAccessor

public MessageHeaderContextAccessor()

Method Details

readableType

@NonNull
public Class<? extends MessageHeaders> readableType()

Specified by:

readableType in interface io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

readValues

public void readValues(MessageHeaders sourceContext,
 @NonNull
 Predicate<Object> keyPredicate,
 @NonNull
 Map<Object,Object> target)

Specified by:

readValues in interface io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

readValue

public <T> T readValue(MessageHeaders sourceContext,
 Object key)

Specified by:

readValue in interface io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

writeableType

@NonNull
public Class<? extends MessageHeaders> writeableType()

Specified by:

writeableType in interface io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>

writeValues

@NonNull
public MessageHeaders writeValues(@NonNull
 Map<Object,Object> valuesToWrite,
 @NonNull
 MessageHeaders targetContext)

Specified by:

writeValues in interface io.micrometer.context.ContextAccessor<MessageHeaders,MessageHeaders>