object QueryCorrelationId
(Optional) mechanism for query implementations to pick up a correlation id from the caller, to use in logging and error messages. Used by akka-projections to make correlating projection logs with debug and trace logging from the underlying akka persistence query implementations possible.
- Source
- QueryCorrelationId.scala
- Alphabetic
- By Inheritance
- QueryCorrelationId
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def callWithCorrelationId[T](correlationId: String, function: Supplier[T]): T
Java API: Expected to be used "around" calls to plugin query method, will clear the correlation id from thread local to make sure there is no leak between logic executed on shared threads.
- def callWithCorrelationId[T](correlationId: Optional[String], function: Supplier[T]): T
Java API: Expected to be used "around" calls to plugin query method to pass along a previously extracted optional correlation id, will clear the correlation id from thread local to make sure there is no leak between logic executed on shared threads.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def get(): Option[String]
Scala API: Expected to be called by query plugins directly after receiving a query call, before starting any asynchronous tasks.
Scala API: Expected to be called by query plugins directly after receiving a query call, before starting any asynchronous tasks. Calling code is responsible to clear it out after method returns. The value is stored in a thread local so is not available across threads or streams. Further passing around of the uuid inside the query plugin implementation is up to the implementer.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def getCorrelationId(): Optional[String]
Java API: Expected to be called by query plugins directly after receiving a query call, before starting any asynchronous tasks.
Java API: Expected to be called by query plugins directly after receiving a query call, before starting any asynchronous tasks. Calling code is responsible to clear it out after method returns. The value is stored in a thread local so is not available across threads or streams. Further passing around of the uuid inside the query plugin implementation is up to the implementer.
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withCorrelationId[T](correlationId: Option[String])(f: () => T): T
Scala API: Expected to be used "around" calls to plugin query method to pass along a previously extracted optional correlation id, will clear the correlation id from thread local to make sure there is no leak between logic executed on shared threads.
- def withCorrelationId[T](correlationId: String)(f: () => T): T
Scala API: Expected to be used "around" calls to plugin query method, will clear the correlation id from thread local to make sure there is no leak between logic executed on shared threads.