3 writes to CorrelationFilter
Aspire.Hosting.Azure.Tests (2)
AzureServiceBusExtensionsTests.cs (2)
348
CorrelationFilter
= new()
452
CorrelationFilter
= new()
ServiceBus.AppHost (1)
Program.cs (1)
23
CorrelationFilter
= new()
41 references to CorrelationFilter
Aspire.Hosting.Azure.ServiceBus (41)
ServiceBusRule.cs (41)
53
if (
CorrelationFilter
!= null)
57
foreach (var property in
CorrelationFilter
.Properties)
61
if (
CorrelationFilter
.CorrelationId != null)
63
rule.CorrelationFilter.CorrelationId =
CorrelationFilter
.CorrelationId;
65
if (
CorrelationFilter
.MessageId != null)
67
rule.CorrelationFilter.MessageId =
CorrelationFilter
.MessageId;
69
if (
CorrelationFilter
.SendTo != null)
71
rule.CorrelationFilter.SendTo =
CorrelationFilter
.SendTo;
73
if (
CorrelationFilter
.ReplyTo != null)
75
rule.CorrelationFilter.ReplyTo =
CorrelationFilter
.ReplyTo;
77
if (
CorrelationFilter
.Subject != null)
79
rule.CorrelationFilter.Subject =
CorrelationFilter
.Subject;
81
if (
CorrelationFilter
.SessionId != null)
83
rule.CorrelationFilter.SessionId =
CorrelationFilter
.SessionId;
85
if (
CorrelationFilter
.ReplyToSessionId != null)
87
rule.CorrelationFilter.ReplyToSessionId =
CorrelationFilter
.ReplyToSessionId;
89
if (
CorrelationFilter
.ContentType != null)
91
rule.CorrelationFilter.ContentType =
CorrelationFilter
.ContentType;
93
if (
CorrelationFilter
.RequiresPreprocessing.HasValue)
95
rule.CorrelationFilter.RequiresPreprocessing =
CorrelationFilter
.RequiresPreprocessing.Value;
132
writer.WriteStartObject(nameof(
CorrelationFilter
));
134
if (rule.
CorrelationFilter
.Properties.Count != 0)
138
JsonSerializer.Serialize(writer, rule.
CorrelationFilter
.Properties);
140
if (rule.
CorrelationFilter
.CorrelationId != null)
142
writer.WriteString(nameof(ServiceBusCorrelationFilter.CorrelationId), rule.
CorrelationFilter
.CorrelationId);
144
if (rule.
CorrelationFilter
.MessageId != null)
146
writer.WriteString(nameof(ServiceBusCorrelationFilter.MessageId), rule.
CorrelationFilter
.MessageId);
148
if (rule.
CorrelationFilter
.SendTo != null)
151
writer.WriteString("To", rule.
CorrelationFilter
.SendTo);
153
if (rule.
CorrelationFilter
.ReplyTo != null)
155
writer.WriteString(nameof(ServiceBusCorrelationFilter.ReplyTo), rule.
CorrelationFilter
.ReplyTo);
157
if (rule.
CorrelationFilter
.Subject != null)
160
writer.WriteString("Label", rule.
CorrelationFilter
.Subject);
162
if (rule.
CorrelationFilter
.SessionId != null)
164
writer.WriteString(nameof(ServiceBusCorrelationFilter.SessionId), rule.
CorrelationFilter
.SessionId);
166
if (rule.
CorrelationFilter
.ReplyToSessionId != null)
168
writer.WriteString(nameof(ServiceBusCorrelationFilter.ReplyToSessionId), rule.
CorrelationFilter
.ReplyToSessionId);
170
if (rule.
CorrelationFilter
.ContentType != null)
172
writer.WriteString(nameof(ServiceBusCorrelationFilter.ContentType), rule.
CorrelationFilter
.ContentType);
174
if (rule.
CorrelationFilter
.RequiresPreprocessing.HasValue)
176
writer.WriteBoolean(nameof(ServiceBusCorrelationFilter.RequiresPreprocessing), rule.
CorrelationFilter
.RequiresPreprocessing.Value);