You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently, 2 dependencies are used in the worker to create an instance of FetchAndLockRequest:
IOptions<FetchAndLockOptions> which provides WorkerId, MaxTasks, UsePriority, AsyncResponseTimeout
ITopicsProvider which provides set of FetchAndLockRequest.Topic. Existing implementation of this interface is implemented by converting set of HandlerMetadata to set of FetchAndLockRequest.Topic.
These 2 dependencies can be replaced with one that will allow to get an instance of FetchAndLockRequest.
Add an implementation of proposed interface that uses the 2 dependencies described earlier and register it in DI. Change code in DefaultCamundaWorker to use new IFetchAndLockRequestProvider.
Mark ITopicsProvider and ICamundaWorkerBuilder.AddTopicsProvider as obsolete
The text was updated successfully, but these errors were encountered:
Background and motivation
Currently, 2 dependencies are used in the worker to create an instance of FetchAndLockRequest:
IOptions<FetchAndLockOptions>
which providesWorkerId
,MaxTasks
,UsePriority
,AsyncResponseTimeout
ITopicsProvider
which provides set ofFetchAndLockRequest.Topic
. Existing implementation of this interface is implemented by converting set ofHandlerMetadata
to set ofFetchAndLockRequest.Topic
.These 2 dependencies can be replaced with one that will allow to get an instance of
FetchAndLockRequest
.Proposal
Add an interface:
Add a class:
Add to ICamundaWorkerBuilder a method for registering the implementation of a new interface with the following signature:
Add an implementation of proposed interface that uses the 2 dependencies described earlier and register it in DI. Change code in
DefaultCamundaWorker
to use newIFetchAndLockRequestProvider
.Mark
ITopicsProvider
andICamundaWorkerBuilder.AddTopicsProvider
as obsoleteThe text was updated successfully, but these errors were encountered: