239CorrelationFilter = new() 347CorrelationFilter = new()

19CorrelationFilter = new()

54if (CorrelationFilter != null) 58foreach (var property in CorrelationFilter.Properties) 62if (CorrelationFilter.CorrelationId != null) 64rule.CorrelationFilter.CorrelationId = CorrelationFilter.CorrelationId; 66if (CorrelationFilter.MessageId != null) 68rule.CorrelationFilter.MessageId = CorrelationFilter.MessageId; 70if (CorrelationFilter.SendTo != null) 72rule.CorrelationFilter.SendTo = CorrelationFilter.SendTo; 74if (CorrelationFilter.ReplyTo != null) 76rule.CorrelationFilter.ReplyTo = CorrelationFilter.ReplyTo; 78if (CorrelationFilter.Subject != null) 80rule.CorrelationFilter.Subject = CorrelationFilter.Subject; 82if (CorrelationFilter.SessionId != null) 84rule.CorrelationFilter.SessionId = CorrelationFilter.SessionId; 86if (CorrelationFilter.ReplyToSessionId != null) 88rule.CorrelationFilter.ReplyToSessionId = CorrelationFilter.ReplyToSessionId; 90if (CorrelationFilter.ContentType != null) 92rule.CorrelationFilter.ContentType = CorrelationFilter.ContentType; 94if (CorrelationFilter.RequiresPreprocessing.HasValue) 96rule.CorrelationFilter.RequiresPreprocessing = CorrelationFilter.RequiresPreprocessing.Value; 133writer.WriteStartObject(nameof(CorrelationFilter)); 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);