Packages

object IronMqProducer

Source
IronMqProducer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IronMqProducer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def atLeastOnceFlow[ToCommit, CommitResult, CommitMat](queueName: String, settings: IronMqSettings, commitFlow: Flow[ToCommit, CommitResult, CommitMat]): Flow[(PushMessage, ToCommit), (Id, CommitResult), CommitMat]

    A more generic committable aware producer Flow that can be used for other committable source, like Kafka.

    A more generic committable aware producer Flow that can be used for other committable source, like Kafka. The user is responsible to supply the committing flow. The result of the commit is emitted as well as the materialized value of the committing flow.

  2. def atLeastOnceFlow(queueName: String, settings: IronMqSettings): Flow[(PushMessage, Committable), Id, NotUsed]

    A Committable aware producer Flow that consume Committable), push messages on IronMq and commit the associated Committable.

  3. def atLeastOnceSink[ToCommit, CommitResult, CommitMat](queueName: String, settings: IronMqSettings, commitFlow: Flow[ToCommit, CommitResult, CommitMat]): Sink[(PushMessage, ToCommit), CommitMat]

    A more generic committable aware producer Sink that can be used for other committable source, like Kafka.

    A more generic committable aware producer Sink that can be used for other committable source, like Kafka. The user is responsible to supply the committing flow. The materialized value of the committing flow is returned.

  4. def atLeastOnceSink(queueName: String, settings: IronMqSettings): Sink[(PushMessage, Committable), NotUsed]

    A Committable aware producer Sink that consume Committable) push messages on IronMq and commit the associated Committable.

  5. def flow(queueName: String, settings: IronMqSettings): Flow[PushMessage, Id, NotUsed]

    This is plain producer Flow that consume PushMessage and emit Message.Id for each produced message.

  6. def sink(queueName: String, settings: IronMqSettings): Sink[PushMessage, Future[Done]]

    A plain producer Sink that consume PushMessage and push them on IronMq.