trait EventConsumerService extends AnyRef

EventConsumerService runs on the consumer side and allows a producer to initiate/push events to the consumer.

  1. Events are stored in the event journal on the producer side. 2. Producer side starts an Akka Projection which locally tracks its offset and as projection handler pushes events to a consuming EventConsumerService 3. Consumer stores events directly into a journal 4. Consumer side projections can run against the local journal
Annotations
@AkkaGrpcGenerated()
Source
EventConsumerService.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
EventConsumerServiceClient
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventConsumerService
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def consumeEvent(in: Source[ConsumeEventIn, NotUsed]): Source[ConsumeEventOut, NotUsed]