Skip to main content

LeaseTriggerMessage

Namespace: Meshmakers.Octo.Communication.Contracts.MessageObjects

Cron tick for a pipeline whose adapter is Leased (AB#5278, Epic AB#4914). A leased adapter has no process of its own, so the per-pipeline trigger queue a dedicated adapter consumes through FromPipelineTriggerEvent@1 has no consumer — and a pool member that happens to hold a lease must not consume it either, because a run that starts that way bypasses the lease bookkeeping (no queued execution, no queue position, no lease span). For such a pipeline the controller therefore registers the recurring send with THIS message to its own durable queue (PipelineQueueNames.LeaseTriggerQueue) instead of the adapter's queue, and turns every tick into a queued work item exactly as an explicit ExecutePipeline would.

public record LeaseTriggerMessage : IEquatable<LeaseTriggerMessage>

Inheritance Object → LeaseTriggerMessage
Implements IEquatable<LeaseTriggerMessage>

Properties​

TenantId​

Tenant the pipeline belongs to (the borrower).

public string TenantId { get; set; }

Property Value​

String

PipelineRtId​

Runtime entity id of the pipeline the cron fires.

public string PipelineRtId { get; set; }

Property Value​

String

TriggerRtId​

Runtime entity id of the PipelineTrigger that owns the cron, for diagnostics.

public string TriggerRtId { get; set; }

Property Value​

String

Constructors​

LeaseTriggerMessage(String, String, String)​

Cron tick for a pipeline whose adapter is Leased (AB#5278, Epic AB#4914). A leased adapter has no process of its own, so the per-pipeline trigger queue a dedicated adapter consumes through FromPipelineTriggerEvent@1 has no consumer — and a pool member that happens to hold a lease must not consume it either, because a run that starts that way bypasses the lease bookkeeping (no queued execution, no queue position, no lease span). For such a pipeline the controller therefore registers the recurring send with THIS message to its own durable queue (PipelineQueueNames.LeaseTriggerQueue) instead of the adapter's queue, and turns every tick into a queued work item exactly as an explicit ExecutePipeline would.

public LeaseTriggerMessage(string TenantId, string PipelineRtId, string TriggerRtId)

Parameters​

TenantId String
Tenant the pipeline belongs to (the borrower).

PipelineRtId String
Runtime entity id of the pipeline the cron fires.

TriggerRtId String
Runtime entity id of the PipelineTrigger that owns the cron, for diagnostics.