class DirectSequencerSubscriptionFactory extends NamedLogging
Factory for creating resilient subscriptions directly to an in-process sequencer.Sequencer
- Alphabetic
- By Inheritance
- DirectSequencerSubscriptionFactory
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DirectSequencerSubscriptionFactory(sequencer: Sequencer, timeouts: ProcessingTimeout, loggerFactory: NamedLoggerFactory)(implicit materializer: Materializer, executionContext: ExecutionContext)
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() @HotSpotIntrinsicCandidate()
- def create[E](startingAt: SequencerCounter, identifier: String, member: Member, handler: SerializedEventHandler[E])(implicit traceContext: TraceContext): EitherT[Future, CreateSubscriptionError, SequencerSubscription[E]]
Create a subscription for an event handler to observe sequencer events for this member.
Create a subscription for an event handler to observe sequencer events for this member. By connecting from
startingAtit is assumed that all prior events have been successfully read by the member (and may be removed by a separate administrative process). Closing the returned subscription should disconnect the handler. If member is unknown by the sequencer a sequencer.errors.CreateSubscriptionError.UnknownMember error will be returned. If the counter is invalid (currently will only happen if counter <0) a sequencer.errors.CreateSubscriptionError.InvalidCounter error will be returned.- startingAt
Counter of the next event to observe. (e.g. 0 will return the first event when it is available)
- identifier
a name to attach to the connection
- member
Member to subscribe on behalf of.
- handler
The handler to invoke with sequencer events
- returns
A running subscription
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- DirectSequencerSubscriptionFactory → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])