PipelineDataEventAddresses
Namespace: Meshmakers.Octo.Sdk.Common.Services
The one place that names the queue a FromPipelineDataEvent@1 trigger consumes and a
ToPipelineDataEvent@1 node publishes to (AB#5231). A durable, named queue per target
pipeline: a message published while the target's workload is scaled to zero waits on the
broker instead of vanishing into an exchange with no bound queue, and every replica of the
target competes on the same queue instead of each getting a copy.
public static class PipelineDataEventAddresses
Inheritance Object → PipelineDataEventAddresses
Methods
QueueName(String, OctoObjectId)
Queue name (without the queue: scheme) for events addressed to pipelineRtId.
public static string QueueName(string tenantId, OctoObjectId pipelineRtId)
Parameters
tenantId String
pipelineRtId OctoObjectId
Returns
QueueAddress(String, OctoObjectId)
The send address of that queue.
public static Uri QueueAddress(string tenantId, OctoObjectId pipelineRtId)
Parameters
tenantId String
pipelineRtId OctoObjectId
Returns
Uri