final class ZWorkerFactory extends AnyRef
Maintains worker creation and lifecycle.
- See also
WorkerFactory
- Alphabetic
- By Inheritance
- ZWorkerFactory
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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]) @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- def getWorker(taskQueue: String): UIO[Option[ZWorker]]
- taskQueue
task queue name to lookup an existing worker for
- returns
a worker created previously through newWorker for the given task queue.
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newWorker(taskQueue: String, options: ZWorkerOptions = ZWorkerOptions.default): UIO[ZWorker]
Creates worker that connects to an instance of the Temporal Service.
Creates worker that connects to an instance of the Temporal Service. It uses the namespace configured at the Factory level. New workers cannot be created after the start() has been called
- taskQueue
task queue name worker uses to poll. It uses this name for both workflow and activity task queue polls.
- options
Options for configuring worker.
- returns
ZWorker
- See also
WorkerFactory#newWorker
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def serve: URIO[Scope, Nothing]
Allows to setup ZWorkerFactory with guaranteed finalization.
Allows to setup ZWorkerFactory with guaranteed finalization. To be used in worker-only applications
- def setup: URIO[Scope, Unit]
Allows to setup ZWorkerFactory with guaranteed finalization.
- def shutdown: UIO[Unit]
Initiates an orderly shutdown in which polls are stopped and already received workflow and activity tasks are executed.
Initiates an orderly shutdown in which polls are stopped and already received workflow and activity tasks are executed.
- See also
WorkerFactory#shutdown
- def shutdownNow: UIO[Unit]
Initiates an orderly shutdown in which polls are stopped and already received workflow and activity tasks are attempted to be stopped.
Initiates an orderly shutdown in which polls are stopped and already received workflow and activity tasks are attempted to be stopped. This implementation cancels tasks via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate.
- See also
WorkerFactory#shutdownNow
- def start: UIO[Unit]
Starts all the workers created by this factory.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val toJava: WorkerFactory
- 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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)