wow-core/me.ahoo.wow.messaging/DefaultHeader

DefaultHeader

class DefaultHeader(delegate: MutableMap<String, String> = mutableMapOf(), var isReadOnly: Boolean = false) : Header, MutableMap<String, String>

Default Header implementation.

Author

ahoo wang

Constructors

DefaultHeader

constructor(delegate: MutableMap<String, String> = mutableMapOf(), isReadOnly: Boolean = false)

Types

Companion

object Companion

Properties

compensationId

val Header.compensationId: String?

entries

open override val entries: MutableSet<MutableMap.MutableEntry<String, String>>

isReadOnly

@Volatile

open override var isReadOnly: Boolean

keys

open override val keys: MutableSet<String>

operator

val Header.operator: String?

requiredOperator

val Header.requiredOperator: String

size

open override val size: Int

traceId

val Header.traceId: String?

upstreamId

val Header.upstreamId: String?

upstreamName

val Header.upstreamName: String?

values

open override val values: MutableCollection<String>

Functions

clear

open override fun clear()

compute

open fun compute(p0: String, p1: BiFunction<in String, in String?, out String?>): String?

computeIfAbsent

open fun computeIfAbsent(p0: String, p1: Function<in String, out String>): String

computeIfPresent

open fun computeIfPresent(p0: String, p1: BiFunction<in String, in String, out String?>): String?

containsKey

open override fun containsKey(key: String): Boolean

containsValue

open override fun containsValue(value: String): Boolean

copy

open override fun copy(): Header

equals

open operator override fun equals(other: Any?): Boolean

extractWaitStrategy

fun Header.extractWaitStrategy(): WaitStrategyInfo?

forEach

open fun forEach(p0: BiConsumer<in String, in String>)

get

open operator override fun get(key: String): String?

getOrDefault

open fun getOrDefault(key: String, defaultValue: String): String

hashCode

open override fun hashCode(): Int

inject

fun Header.inject(upstream: Message<*, *>): Header

injectWaitStrategy

fun Header.injectWaitStrategy(commandWaitEndpoint: String, stage: CommandStage, context: String, processor: String = ""): Header

isEmpty

open override fun isEmpty(): Boolean

isLocalFirst

fun Header.isLocalFirst(): Boolean

match

fun Header.match(function: FunctionInfo): Boolean

merge

open fun merge(p0: String, p1: String, p2: BiFunction<in String, in String, out String?>): String?

put

open override fun put(key: String, value: String): String?

putAll

open override fun putAll(from: Map<out String, String>)

putIfAbsent

open fun putIfAbsent(p0: String, p1: String): String?

remove

open override fun remove(key: String): String?

open override fun remove(key: String, value: String): Boolean

replace

open fun replace(p0: String, p1: String): String?

open fun replace(p0: String, p1: String, p2: String): Boolean

replaceAll

open fun replaceAll(p0: BiFunction<in String, in String, out String>)

toHeader

fun Map<String, String>?.toHeader(): Header

toString

open override fun toString(): String

with

open fun with(additional: Map<String, String>): Header

open fun with(key: String, value: String): Header

withCompensation

fun Header.withCompensation(target: CompensationTarget): Header

withLocalFirst

fun Header.withLocalFirst(localFirst: Boolean = true): Header

withOperator

fun Header.withOperator(operator: String): Header

withReadOnly

open override fun withReadOnly(): Header

withTraceId

fun Header.withTraceId(traceId: String): Header

withUpstreamId

fun Header.withUpstreamId(upstreamId: String): Header

withUpstreamName

fun Header.withUpstreamName(upstreamName: String): Header