Polish RabbitTemplateConfigurer allowed-list-patterns
Closes gh-41349
This commit is contained in:
parent
5b9c0006e9
commit
3aee73004a
|
@ -108,17 +108,17 @@ public class RabbitTemplateConfigurer {
|
||||||
map.from(templateProperties::isObservationEnabled).to(template::setObservationEnabled);
|
map.from(templateProperties::isObservationEnabled).to(template::setObservationEnabled);
|
||||||
map.from(templateProperties::getAllowedListPatterns)
|
map.from(templateProperties::getAllowedListPatterns)
|
||||||
.whenNot(CollectionUtils::isEmpty)
|
.whenNot(CollectionUtils::isEmpty)
|
||||||
.to((allowListPatterns) -> setAllowedListPatterns(template.getMessageConverter(), allowListPatterns));
|
.to((allowedListPatterns) -> setAllowedListPatterns(template.getMessageConverter(), allowedListPatterns));
|
||||||
}
|
}
|
||||||
|
|
||||||
private void setAllowedListPatterns(MessageConverter messageConverter, List<String> allowListPatterns) {
|
private void setAllowedListPatterns(MessageConverter messageConverter, List<String> allowedListPatterns) {
|
||||||
if (messageConverter instanceof AllowedListDeserializingMessageConverter allowedListDeserializingMessageConverter) {
|
if (messageConverter instanceof AllowedListDeserializingMessageConverter allowedListDeserializingMessageConverter) {
|
||||||
allowedListDeserializingMessageConverter.setAllowedListPatterns(allowListPatterns);
|
allowedListDeserializingMessageConverter.setAllowedListPatterns(allowedListPatterns);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
throw new InvalidConfigurationPropertyValueException("spring.rabbitmq.template.allow-list-patterns",
|
throw new InvalidConfigurationPropertyValueException("spring.rabbitmq.template.allowed-list-patterns",
|
||||||
allowListPatterns,
|
allowedListPatterns,
|
||||||
"Allow list patterns can only be applied to a AllowedListDeserializingMessageConverter");
|
"Allowed list patterns can only be applied to an AllowedListDeserializingMessageConverter");
|
||||||
}
|
}
|
||||||
|
|
||||||
private boolean determineMandatoryFlag() {
|
private boolean determineMandatoryFlag() {
|
||||||
|
|
Loading…
Reference in New Issue