240CorrelationFilter = new() 348CorrelationFilter = new()

19CorrelationFilter = new()

55if (CorrelationFilter != null) 59foreach (var property in CorrelationFilter.Properties) 63if (CorrelationFilter.CorrelationId != null) 65rule.CorrelationFilter.CorrelationId = CorrelationFilter.CorrelationId; 67if (CorrelationFilter.MessageId != null) 69rule.CorrelationFilter.MessageId = CorrelationFilter.MessageId; 71if (CorrelationFilter.SendTo != null) 73rule.CorrelationFilter.SendTo = CorrelationFilter.SendTo; 75if (CorrelationFilter.ReplyTo != null) 77rule.CorrelationFilter.ReplyTo = CorrelationFilter.ReplyTo; 79if (CorrelationFilter.Subject != null) 81rule.CorrelationFilter.Subject = CorrelationFilter.Subject; 83if (CorrelationFilter.SessionId != null) 85rule.CorrelationFilter.SessionId = CorrelationFilter.SessionId; 87if (CorrelationFilter.ReplyToSessionId != null) 89rule.CorrelationFilter.ReplyToSessionId = CorrelationFilter.ReplyToSessionId; 91if (CorrelationFilter.ContentType != null) 93rule.CorrelationFilter.ContentType = CorrelationFilter.ContentType; 95if (CorrelationFilter.RequiresPreprocessing.HasValue) 97rule.CorrelationFilter.RequiresPreprocessing = CorrelationFilter.RequiresPreprocessing.Value; 134writer.WriteStartObject(nameof(CorrelationFilter)); 136if (rule.CorrelationFilter.Properties.Count != 0) 140JsonSerializer.Serialize(writer, rule.CorrelationFilter.Properties); 142if (rule.CorrelationFilter.CorrelationId != null) 144writer.WriteString(nameof(AzureServiceBusCorrelationFilter.CorrelationId), rule.CorrelationFilter.CorrelationId); 146if (rule.CorrelationFilter.MessageId != null) 148writer.WriteString(nameof(AzureServiceBusCorrelationFilter.MessageId), rule.CorrelationFilter.MessageId); 150if (rule.CorrelationFilter.SendTo != null) 153writer.WriteString("To", rule.CorrelationFilter.SendTo); 155if (rule.CorrelationFilter.ReplyTo != null) 157writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ReplyTo), rule.CorrelationFilter.ReplyTo); 159if (rule.CorrelationFilter.Subject != null) 162writer.WriteString("Label", rule.CorrelationFilter.Subject); 164if (rule.CorrelationFilter.SessionId != null) 166writer.WriteString(nameof(AzureServiceBusCorrelationFilter.SessionId), rule.CorrelationFilter.SessionId); 168if (rule.CorrelationFilter.ReplyToSessionId != null) 170writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ReplyToSessionId), rule.CorrelationFilter.ReplyToSessionId); 172if (rule.CorrelationFilter.ContentType != null) 174writer.WriteString(nameof(AzureServiceBusCorrelationFilter.ContentType), rule.CorrelationFilter.ContentType); 176if (rule.CorrelationFilter.RequiresPreprocessing.HasValue) 178writer.WriteBoolean(nameof(AzureServiceBusCorrelationFilter.RequiresPreprocessing), rule.CorrelationFilter.RequiresPreprocessing.Value);