final class EventProducerSource extends AnyRef
- Annotations
- @ApiMayChange()
- Source
- EventProducerSource.scala
- Alphabetic
- By Inheritance
- EventProducerSource
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new EventProducerSource(entityType: String, streamId: String, transformation: Transformation, settings: EventProducerSettings, producerFilter: Predicate[EventEnvelope[Any]])
- new EventProducerSource(entityType: String, streamId: String, transformation: Transformation, settings: EventProducerSettings)
- new EventProducerSource(entityType: String, streamId: String, transformation: Transformation, settings: EventProducerSettings, transformSnapshot: Optional[Function[Any, Any]])
- new EventProducerSource(entityType: String, streamId: String, transformation: Transformation, settings: EventProducerSettings, producerFilter: Predicate[EventEnvelope[Any]], transformSnapshot: Optional[Function[Any, Any]], replicatedEventOriginFilter: Option[EventOriginFilter])
- entityType
The internal entity type name
- streamId
The public, logical, stream id that consumers use to consume this source
- transformation
Transformations for turning the internal events to public message types
- settings
The event producer settings used (can be shared for multiple sources)
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 asScala: scaladsl.EventProducer.EventProducerSource
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val entityType: String
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- 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()
- val producerFilter: Predicate[EventEnvelope[Any]]
- val settings: EventProducerSettings
- val streamId: String
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- val transformSnapshot: Optional[Function[Any, Any]]
- val transformation: Transformation
- 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 withProducerFilter[Event](producerFilter: Predicate[EventEnvelope[Event]]): EventProducerSource
Filter events matching the predicate, for example based on tags.
- def withStartingFromSnapshots[Snapshot, Event](transformSnapshot: Function[Snapshot, Event]): EventProducerSource
Use snapshots as starting points and thereby reducing number of events that have to be loaded.
Use snapshots as starting points and thereby reducing number of events that have to be loaded. This can be useful if the consumer start from zero without any previously processed offset or if it has been disconnected for a long while and its offset is far behind.
First it loads all snapshots with timestamps greater than or equal to the offset timestamp. There is at most one snapshot per persistenceId. The snapshots are transformed to events with the given
transformSnapshotfunction.After emitting the snapshot events the ordinary events with sequence numbers after the snapshots are emitted.
Important note: This should not be used together with EventProducerPush. In that case
SourceProviderwitheventsBySlicesStartingFromSnapshotsshould be used instead. - def withTopicProducerFilter(topicExpression: String): EventProducerSource
Filter events matching the topic expression according to MQTT specification, including wildcards.
Filter events matching the topic expression according to MQTT specification, including wildcards. The topic of an event is defined by a tag with certain prefix, see
topic-tag-prefixconfiguration.