seg_yinzy
/
che-server
mirror of https://github.com/eclipse-che/che-server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixed npe in subscription manager 

Signed-off-by: Dmitry Kuleshov <dkuleshov@codenvy.com>
6.19.x
Dmitry Kuleshov 2017-05-30 11:30:23 +03:00
parent 1379fbf602
commit 9d033293ff
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/che-core-api-core/src/main/java/org/eclipse/che/api/core/notification/RemoteSubscriptionManager.java
View File

@ -22,13 +22,14 @@ import java.util.HashSet;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.BiPredicate;
import static java.util.Collections.emptySet;
@Singleton
public class RemoteSubscriptionManager {
private final Map<String, Set<SubscriptionContext>> subscriptionContexts = new HashMap<>();
private final Map<String, Set<SubscriptionContext>> subscriptionContexts = new ConcurrentHashMap<>();
private final EventService eventService;
private final RequestTransmitter requestTransmitter;
@ -56,7 +57,7 @@ public class RemoteSubscriptionManager {
}
public <T> void register(String method, Class<T> eventType, BiPredicate<T, Map<String, String>> biPredicate) {
eventService.subscribe(event -> subscriptionContexts.get(method)
eventService.subscribe(event -> subscriptionContexts.getOrDefault(method, new HashSet<>())
.stream()
.filter(context -> biPredicate.test(event, context.scope))
.forEach(context -> transmit(context.endpointId, method, event)),