class Client extends DurableQueue
Provides an implementation of DurableQueue that communicates
with a server via MQTT.
- Annotations
- @SuppressWarnings()
- Alphabetic
- By Inheritance
- Client
- DurableQueue
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Client(appenderGroupSize: Int, appenderGroupWindow: FiniteDuration, clientId: String, commitBufferSize: Int, connectionParameters: ConnectionParameters, defaultNamespace: String, reconnectMinBackoff: FiniteDuration, reconnectMaxBackoff: FiniteDuration, reconnectMaxRestarts: Int, reconnectRandomFactor: Double, tailerQueueSize: Int)(implicit system: ActorSystem)
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(classOf[java.lang.CloneNotSupportedException]) @native()
- def commit[A](tailerId: UUID): Flow[(Committable, A), A, NotUsed]
A flow that tracks consumed offsets, and when successfully consumed stores the offset.
A flow that tracks consumed offsets, and when successfully consumed stores the offset. Due to the nature of distributed systems, tailers should be able to gracefully consume the same messages more than once, given that e.g. the commit operation could fail.
- tailerId
An id for the tailer. Named (V3 or V5) UUIDs are recommended for deterministic UUID calculation.
- returns
A flow that accepts
CommittableEventinstance and a carry element and stores their offsets, emitting the carry element.
- Definition Classes
- Client → DurableQueue
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def flow[A]: Flow[CommandRequest[A], CommandReply[A], NotUsed]
Append a command request to a queue
Append a command request to a queue
- A
The type of data to carry through
- returns
a flow that takes a command and returns with an acknowledgement
- Definition Classes
- Client → DurableQueue
- final def getClass(): Class[_ <: AnyRef]
- 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 offset(topic: Topic, tailerId: UUID): Future[Option[Long]]
Returns the latest offset a given tailer has committed.
Returns the latest offset a given tailer has committed.
- tailerId
An id for the tailer. Named (V3 or V5) UUIDs are recommended for deterministic UUID calculation.
- Definition Classes
- Client → DurableQueue
- def sink[A]: Sink[CommandRequest[A], Future[Done]]
Append a command request to a queue via a sink for convenience
Append a command request to a queue via a sink for convenience
- A
The type of data to carry through
- returns
a sink that takes a command and returns with an acknowledgement
- Definition Classes
- DurableQueue
- Annotations
- @SuppressWarnings()
- def source(topic: Topic, offset: Option[Long], finite: Boolean): Source[Received, NotUsed]
Tail the queue for received events
Tail the queue for received events
- topic
the specific topic to tail
- offset
an optional index at which to start tailing
- finite
if true, stop tailing once the end of the queue has been reached
- returns
a source representing the tail of events
- Definition Classes
- DurableQueue
- def source(topic: Topic, offset: Option[Long]): Source[Received, NotUsed]
Tail the queue for received events
Tail the queue for received events
- topic
the specific topic to tail
- offset
an optional index at which to start tailing
- returns
a source representing the tail of events
- Definition Classes
- DurableQueue
- def source(topic: Topic): Source[Received, NotUsed]
Tail the queue for received events
Tail the queue for received events
- topic
the specific topic to tail
- returns
a source representing the tail of events
- Definition Classes
- DurableQueue
- def sourceEvent(topic: Topic, offset: Option[Long], finite: Boolean): Source[Event, NotUsed]
Tail the queue for a variety of events
Tail the queue for a variety of events
- topic
the specific topic to tail
- offset
an optional index at which to start tailing
- finite
if true, stop tailing once the end of the queue has been reached
- returns
a source representing the tail of events
- Definition Classes
- Client → DurableQueue
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()
- def withNamespace(namespace: String): DurableQueue
Returns a
DurableQueueinstance that guarantees that all topic access is within the provided namespace.Returns a
DurableQueueinstance that guarantees that all topic access is within the provided namespace.- Definition Classes
- DurableQueue