OriginAwareContext

All Superinterfaces:: Context

All Known Subinterfaces:: MessageContext, UpdateContext

public interface OriginAwareContext extends Context

Method Summary

Modifier and Type

Method

Description

default boolean

hasLocalOrigin()

Returns true if this message originated in the current processing region, and for messages consumed from a topic or another service.

Optional<String>

originRegion()

When available, this method returns the region where a message was first created.

Methods inherited from interface akka.javasdk.Context
selfRegion

Method Details
- originRegion
  
  Optional<String> originRegion()
  When available, this method returns the region where a message was first created.
  
  It returns a non-empty Optional when consuming events from an EventSourcedEntity, a change updates from a KeyValueEntity or a Workflow
  It returns an empty Optional when consuming messages from a topic (see Consume.FromTopic) or from another service (see Consume.FromServiceStream)
  Returns:
  
  the region where a message was first created. When not applicable, it returns an empty Optional.
- hasLocalOrigin
  
  default boolean hasLocalOrigin()
  Returns true if this message originated in the current processing region, and for messages consumed from a topic or another service.
  The result depends on the message source:
  
  If the message originates from an EventSourcedEntity, KeyValueEntity, or Workflow in the same region as this consumer is running, it returns true.
  When consuming messages from another service (see Consume.FromServiceStream) or from a topic (see Consume.FromTopic), it returns true. This does not establish where the message was created or prevent processing in multiple regions.
  Returns:
  
  true if the message originated from a component in the current processing region, from a broker or from service-to-service eventing, false otherwise.