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