class ZWorker extends AnyRef
Hosts activity and workflow implementations. Uses long poll to receive activity and workflow tasks and processes them in a correspondent thread pool.
- Alphabetic
- By Inheritance
- ZWorker
- 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
- def addActivityImplementation[A <: AnyRef](activity: A)(implicit arg0: ExtendsActivity[A]): UIO[ZWorker]
Registers activity implementation objects with a worker.
Registers activity implementation objects with a worker. An implementation object can implement one or more activity types.
- See also
Worker#registerActivitiesImplementations
- def addActivityImplementationService[A <: AnyRef](implicit arg0: ExtendsActivity[A], arg1: Tag[A]): URIO[A, ZWorker]
Registers activity implementation objects with a worker.
Registers activity implementation objects with a worker. An implementation object can implement one or more activity types.
- See also
Worker#registerActivitiesImplementations
- def addActivityImplementations(activityImplementationObjects: List[ZActivityImplementationObject[_]]): UIO[ZWorker]
Register activity implementation objects with a worker.
Register activity implementation objects with a worker. An implementation object can implement one or more activity types.
An activity implementation object must implement at least one interface annotated with zio.temporal.activityInterface. Each method of the annotated interface becomes an activity type.
Implementations that share a worker must implement different interfaces as an activity type is identified by the activity interface, not by the implementation.
- def addActivityImplementations(activityImplementationObject: ZActivityImplementationObject[_], moreObjects: ZActivityImplementationObject[_]*): UIO[ZWorker]
- See also
- def addWorkflow[I](implicit arg0: ExtendsWorkflow[I]): AddWorkflowDsl[I]
Adds workflow to this worker
- def addWorkflowImplementations(options: ZWorkflowImplementationOptions, workflowImplementationClasses: List[ZWorkflowImplementationClass[_]]): UIO[ZWorker]
- See also
- def addWorkflowImplementations(options: ZWorkflowImplementationOptions, workflowImplementationClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): UIO[ZWorker]
- See also
- def addWorkflowImplementations(workflowImplementationClasses: List[ZWorkflowImplementationClass[_]]): UIO[ZWorker]
Registers workflow implementation classes with a worker.
Registers workflow implementation classes with a worker. Can be called multiple times to add more types. A workflow implementation class must implement at least one interface with a method annotated with zio.temporal.workflowMethod. By default, the short name of the interface is used as a workflow type that this worker supports.
Implementations that share a worker must implement different interfaces as a workflow type is identified by the workflow interface, not by the implementation.
- Exceptions thrown
io.temporal.worker.TypeAlreadyRegisteredExceptionif one of the workflow types is already registered
- def addWorkflowImplementations(workflowImplementationClass: ZWorkflowImplementationClass[_], moreClasses: ZWorkflowImplementationClass[_]*): UIO[ZWorker]
- See also
- 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 hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isSuspended: UIO[Boolean]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def resumePolling: UIO[Unit]
- def suspendPolling: UIO[Unit]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def taskQueue: String
- val toJava: Worker
- def toString(): String
- Definition Classes
- ZWorker → 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)