SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added a check for missing bean

Browse Source
This commit is contained in:
Marcin Grzejszczak
2016-09-02 16:06:15 +02:00
parent 423e42cb1d
commit 18b5cf8890
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java
View File

@@ -81,21 +81,25 @@ public class StreamStubMessages implements MessageVerifier<Message<?>> {
}
private String resolvedDestination(String destination) {
ChannelBindingServiceProperties channelBindingServiceProperties = this.context
.getBean(ChannelBindingServiceProperties.class);
for (Map.Entry<String, BindingProperties> entry : channelBindingServiceProperties
.getBindings().entrySet()) {
if (entry.getValue().getDestination().equals(destination)) {
if (log.isDebugEnabled()) {
log.debug("Found a channel named [{}] with destination [{}]",
entry.getKey(), destination);
try {
ChannelBindingServiceProperties channelBindingServiceProperties = this.context
.getBean(ChannelBindingServiceProperties.class);
for (Map.Entry<String, BindingProperties> entry : channelBindingServiceProperties
.getBindings().entrySet()) {
if (entry.getValue().getDestination().equals(destination)) {
if (log.isDebugEnabled()) {
log.debug("Found a channel named [{}] with destination [{}]",
entry.getKey(), destination);
}
return entry.getKey();
}
return entry.getKey();
}
} catch (Exception e) {
log.error("Exception took place while trying to resolve the destination. Will assume the name [" + destination + "]", e);
}
if (log.isDebugEnabled()) {
log.debug(
"No destination named [{}] was found. Assuming that the destination equals the channel name",
"No destination named [" + destination + "] was found. Assuming that the destination equals the channel name",
destination);
}
return destination;