Skip to content

Commit

Permalink
Adding log for wildcard mapping for non-supported connectors
Browse files Browse the repository at this point in the history
  • Loading branch information
switschel committed Oct 2, 2024
1 parent a57d695 commit f4f6d30
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -503,7 +503,10 @@ public void updateActiveSubscriptionInbound(Mapping mapping, Boolean create, Boo
}
}
}
} else {
log.warn("Tenant {} - Mapping {} contains wildcards like #,+ which are not support by connector {}",tenant, mapping.getId(), connectorName);
}

}
}

Expand All @@ -525,6 +528,8 @@ public void updateActiveSubscriptionsInbound(List<Mapping> updatedMappings, bool
updatedMappings.forEach(mapping -> {
Boolean containsWildcards = mapping.subscriptionTopic.matches(".*[#\\+].*");
boolean validDeployment = (supportsWildcardsInTopic() || !containsWildcards);
if(!validDeployment)
log.warn("Tenant {} - Mapping {} contains wildcards like #,+ which are not support by connector {}",tenant, mapping.getId(), connectorName);
List<String> deploymentMapEntry = mappingComponent.getDeploymentMapEntry(tenant, mapping.ident);
boolean isDeployed = false;
if (deploymentMapEntry != null) {
Expand Down

0 comments on commit f4f6d30

Please sign in to comment.