ServiceBusEnabledAgentBase<T, Q>
If not overridden, agent-like behavior is seen, where a failed message is not reprocessed.
If set to false, messages which have an error when handled will be retried according to the bus's redelivery logic.
Defines how many priorities should be used for this agent. For each priority, a seperate subscription is created on
the request topic.
The default value is 3.
Defines what priorities there are. If no priorities are present, return New Integer() {} , and use topics.
If priorities are present, use Queues (But for now, we have topics).
Determines whether the PriorityQueue should spin up a thread to do the following work: If the PriorityQueue Thinks work is in progress, but it has been this long since any jobs have been completed, the PriorityQueue may conclude it needs to release slots and allow new threads to begin
Percent in the form of a number between 0 and 1, e.g. .5
If ShouldDoIdleThreadChecking is true, and the PriorityQueue Thinks work is in progress, but it has been this long since any jobs have been completed, the PriorityQueue may conclude it needs to release slots and allow new threads to begin.
public ServiceBusEnabledAgentBase()
protected abstract void CreateError(string fullError, string message, int caseArtifactId, string source)
public abstract void HandleMessage(T message, IDictionary<string, object> messageProperties, IDictionary<string, object> additionalProperties = null)
Allows the consuming class to set properties on the SubscriptionDetails object.
If not overridden, defaults will be used.
Allows the consuming class to set properties on the TopicDetails object.
If not overridden, defaults will be used.
protected void SendResponse(Q response, IDictionary<string, object> messageProperties = null, IDictionary<string, object> additionalProperties = null, int retries = 0)