object TopicProducer
Creates topic producers.
This can be used to help implement Topic calls on services, a service that returns these topics will automatically have these streams published while the service is running, sharded across the services nodes.
- Source
- TopicProducer.scala
- Alphabetic
- By Inheritance
- TopicProducer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
singleStreamWithOffset[Message](eventStream: (Offset) ⇒ Source[(Message, Offset), Any]): Topic[Message]
Publish a single stream.
Publish a single stream.
This producer will ensure every element from the stream will be published at least once (usually only once), using the message offsets to track where in the stream the producer is up to publishing.
- eventStream
A function to create the event stream given the last offset that was published.
- returns
The topic producer.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
taggedStreamWithOffset[Message, Event <: AggregateEvent[Event]](shards: AggregateEventShards[Event])(eventStream: (AggregateEventTag[Event], Offset) ⇒ Source[(Message, Offset), Any]): Topic[Message]
Publish all tags of a stream that is sharded across many tags.
Publish all tags of a stream that is sharded across many tags.
The tags will be distributed around the cluster, ensuring that at most one event stream for each tag is being published at a particular time.
This producer will ensure every element from each tags stream will be published at least once (usually only once), using the message offsets to track where in the stream the producer is up to publishing.
- shards
The tags to publish.
- eventStream
A function event stream for a given shard given the last offset that was published.
- returns
The topic producer.
-
def
taggedStreamWithOffset[Message, Event <: AggregateEvent[Event]](tags: Seq[AggregateEventTag[Event]])(eventStream: (AggregateEventTag[Event], Offset) ⇒ Source[(Message, Offset), Any]): Topic[Message]
Publish a stream that is sharded across many tags.
Publish a stream that is sharded across many tags.
The tags will be distributed around the cluster, ensuring that at most one event stream for each tag is being published at a particular time.
This producer will ensure every element from each tags stream will be published at least once (usually only once), using the message offsets to track where in the stream the producer is up to publishing.
- tags
The tags to publish.
- eventStream
A function event stream for a given shard given the last offset that was published.
- returns
The topic producer.
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()