kCura.Agent.ServiceBusEnabledAgentBase<T, Q>

ServiceBusEnabledAgentBase<T, Q>

public abstract class ServiceBusEnabledAgentBase<T, Q> : AgentBase

Documentation

protected string StatusMessage

protected virtual bool CompleteMessageEvenIfErrorIsThrownDuringHandling { get; }

protected int CurrentCallCount { get; protected set; }

public string ErrorFullText { get; }

public virtual string ErrorMessage { get; }

public virtual string ErrorSource { get; }

public bool IsResourcePoolAware { get; }

public abstract int MaxConcurrentCalls { get; }

public virtual TimeSpan MessageHandlerTimeout { get; }

public virtual int NumberOfPriorities { get; }

public virtual int[] Priorities { get; }

public abstract string RequestTopicRoute { get; }

public virtual string ResponseTopicRoute { get; }

public bool ShouldDoIdleThreadChecking { get; }

public virtual bool ShowStandardAgentMessages { get; }

public abstract string SubscriptionName { get; }

public double ThresholdToBeginCheckingForIdleState { get; }

public int ThresholdToDetermineThreadIdleInMinutes { get; }

public virtual int TimeGivenToRenewLockInSeconds { get; }

public ServiceBusEnabledAgentBase()

protected abstract void CreateError(Exception ex)

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)

public virtual void HandleMessages(List<ServiceBusEnabledAgentBaseMessage<T>> messages)

protected virtual ISubscriptionDetails ModifySubscriptionDetails(ISubscriptionDetails details)

protected virtual ITopicDetails ModifyTopicDetails(ITopicDetails details)

protected virtual void ProcessDeadLetteredMessage(string msg)

protected void SendResponse(Q response, IDictionary<string, object> messageProperties = null, IDictionary<string, object> additionalProperties = null, int retries = 0)

public virtual void SetStatusMessage()

public virtual void SubClassAgentDelete()

public virtual void SubClassInit()