Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -108,17 +108,17 @@ public void configure(RabbitTemplate template, ConnectionFactory connectionFacto
map.from(templateProperties::isObservationEnabled).to(template::setObservationEnabled);
map.from(templateProperties::getAllowedListPatterns)
.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) {
allowedListDeserializingMessageConverter.setAllowedListPatterns(allowListPatterns);
allowedListDeserializingMessageConverter.setAllowedListPatterns(allowedListPatterns);
return;
}
throw new InvalidConfigurationPropertyValueException("spring.rabbitmq.template.allow-list-patterns",
allowListPatterns,
"Allow list patterns can only be applied to a AllowedListDeserializingMessageConverter");
throw new InvalidConfigurationPropertyValueException("spring.rabbitmq.template.allowed-list-patterns",
allowedListPatterns,
"Allowed list patterns can only be applied to an AllowedListDeserializingMessageConverter");
}

private boolean determineMandatoryFlag() {
Expand Down