blob: 431f9c18d6d8fbafef69777de553587c4c61738c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
package org.openecomp.sdc.destinationprovider.impl;
import org.apache.commons.lang3.ArrayUtils;
import org.openecomp.sdc.destinationprovider.DestinationProvider;
import org.openecomp.sdc.notification.services.SubscriptionService;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
/**
* @author avrahamg
* @since July 09, 2017
*/
public class MulticastDestination implements DestinationProvider {
private String entityId;
private SubscriptionService subscriptionService;
private String[] excludedSubscribers;
public MulticastDestination(String entityId, SubscriptionService subscriptionService,
String... excludedSubscribers) {
this.entityId = entityId;
this.excludedSubscribers = excludedSubscribers;
this.subscriptionService = subscriptionService;
}
public List<String> getSubscribers() {
ArrayList<String> subscribers = new ArrayList<>(subscriptionService.getSubscribers(entityId));
if (ArrayUtils.isNotEmpty(excludedSubscribers)) {
subscribers.removeAll(Arrays.asList(excludedSubscribers));
}
return Collections.unmodifiableList(subscribers);
}
public String getEntityId() {
return entityId;
}
public void setEntityId(String entityId) {
this.entityId = entityId;
}
}
|
