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

GH-190 Added null check for publisher

Browse Source 
Resolves #190
This commit is contained in:
Oleg Zhurakousky
2018-07-27 16:07:57 +02:00
parent a840689c95
commit 32ee27165b
2 changed files with 60 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/InMemoryFunctionCatalog.java
View File

@@ -90,7 +90,7 @@ public class InMemoryFunctionCatalog
for (String name : registration.getNames()) {
map.put(name, registration.getTarget());
}
publisher.publishEvent(event);
this.publishEvent(event);
}
@Override
@@ -102,7 +102,7 @@ public class InMemoryFunctionCatalog
public void init() {
if (publisher != null && !functions.isEmpty()) {
functions.keySet()
.forEach(type -> publisher.publishEvent(new FunctionRegistrationEvent(this, type, functions.get(type).keySet())));
.forEach(type -> this.publishEvent(new FunctionRegistrationEvent(this, type, functions.get(type).keySet())));
}
}
@@ -110,7 +110,7 @@ public class InMemoryFunctionCatalog
public void close() {
if (publisher != null && !functions.isEmpty()) {
functions.keySet()
.forEach(type -> publisher.publishEvent(new FunctionUnregistrationEvent(this, type, functions.get(type).keySet())));
.forEach(type -> this.publishEvent(new FunctionUnregistrationEvent(this, type, functions.get(type).keySet())));
}
}
@@ -133,4 +133,10 @@ public class InMemoryFunctionCatalog
.map(key -> functions.get(key))
.findFirst().orElse(functions.get(Object.class));
}
private void publishEvent(Object event) {
if (this.publisher != null) {
this.publisher.publishEvent(event);
}
}
}