Package akka.javasdk.annotations

Annotation Interface Consume

public @interface Consume

Annotation for providing ways to consume a stream of messages from Entities, other services, or message broker topics.

Use on Consumer or TableUpdater.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static @interface	Consume.FromEventSourcedEntity	Annotation for consuming events from an EventSourcedEntity.
static @interface	Consume.FromKeyValueEntity	Annotation for consuming state updates from a KeyValueEntity.
static @interface	Consume.FromServiceStream	Annotation for consuming messages from another service.
static @interface	Consume.FromTopic	Annotation for consuming messages from a topic (i.e PubSub or Kafka topic).