20 references to CorrelationFilter
Aspire.Hosting.Azure.ServiceBus (20)
AzureServiceBusRule.cs (20)
135if (rule.CorrelationFilter.Properties.Count != 0)
139JsonSerializer.Serialize(writer, rule.CorrelationFilter.Properties);
141if (rule.CorrelationFilter.CorrelationId != null)
143writer.WriteString(nameof(AzureServiceBusCorrelationFilter.CorrelationId), rule.CorrelationFilter.CorrelationId);
145if (rule.CorrelationFilter.MessageId != null)
147writer.WriteString(nameof(AzureServiceBusCorrelationFilter.MessageId), rule.CorrelationFilter.MessageId);
149if (rule.CorrelationFilter.SendTo != null)
152writer.WriteString("To", rule.CorrelationFilter.SendTo);
154if (rule.CorrelationFilter.ReplyTo != null)
156writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ReplyTo), rule.CorrelationFilter.ReplyTo);
158if (rule.CorrelationFilter.Subject != null)
161writer.WriteString("Label", rule.CorrelationFilter.Subject);
163if (rule.CorrelationFilter.SessionId != null)
165writer.WriteString(nameof(AzureServiceBusCorrelationFilter.SessionId), rule.CorrelationFilter.SessionId);
167if (rule.CorrelationFilter.ReplyToSessionId != null)
169writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ReplyToSessionId), rule.CorrelationFilter.ReplyToSessionId);
171if (rule.CorrelationFilter.ContentType != null)
173writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ContentType), rule.CorrelationFilter.ContentType);
175if (rule.CorrelationFilter.RequiresPreprocessing.HasValue)
177writer.WriteBoolean(nameof(AzureServiceBusCorrelationFilter.RequiresPreprocessing), rule.CorrelationFilter.RequiresPreprocessing.Value);