Revision 51030
Added by Panagiotis Kanakakis about 6 years ago
| BrokerServiceImpl.java | ||
|---|---|---|
| 9 | 9 |
import eu.dnetlib.repo.manager.service.controllers.RepositoryApi; |
| 10 | 10 |
import eu.dnetlib.repo.manager.shared.BrokerException; |
| 11 | 11 |
import eu.dnetlib.repo.manager.shared.RepositoryServiceException; |
| 12 |
import eu.dnetlib.repo.manager.shared.Term; |
|
| 12 | 13 |
import eu.dnetlib.repo.manager.shared.Tuple; |
| 13 | 14 |
import eu.dnetlib.repo.manager.shared.broker.*; |
| 14 | 15 |
import eu.dnetlib.repos.RepoApi; |
| ... | ... | |
| 165 | 166 |
} |
| 166 | 167 |
|
| 167 | 168 |
@Override |
| 168 |
public Map<String, List<SimpleSubscriptionDesc>> getSubscriptionsOfUser(String userEmail) throws BrokerException {
|
|
| 169 |
return brokerApi.getSubscriptionsOfUser(userEmail); |
|
| 169 |
public Map<String, List<SimpleSubscriptionDesc>> getSimpleSubscriptionsOfUser(String userEmail) throws BrokerException {
|
|
| 170 |
return brokerApi.getSimpleSubscriptionsOfUser(userEmail);
|
|
| 170 | 171 |
} |
| 171 | 172 |
|
| 172 | 173 |
@Override |
| ... | ... | |
| 191 | 192 |
} |
| 192 | 193 |
} |
| 193 | 194 |
|
| 195 |
public Map<String,Term> getDnetTopics() throws BrokerException {
|
|
| 196 |
return brokerApi.getDnetTopics(); |
|
| 197 |
} |
|
| 198 |
|
|
| 194 | 199 |
/** |
| 195 | 200 |
* Helper class to aggregate the datasources topic sizes by datasource name. |
| 196 | 201 |
* |
| ... | ... | |
| 224 | 229 |
|
| 225 | 230 |
return entries; |
| 226 | 231 |
} |
| 232 |
|
|
| 233 |
@Override |
|
| 234 |
public EventsPage getNotificationsBySubscriptionId(String subscriptionId,String page,String size) throws BrokerException {
|
|
| 235 |
return brokerApi.getNotificationsBySubscriptionId(subscriptionId,page,size); |
|
| 236 |
} |
|
| 237 |
|
|
| 238 |
@Override |
|
| 239 |
public Map<String, List<Subscription>> getSubscriptionsOfUser(String userEmail) throws BrokerException {
|
|
| 240 |
return brokerApi.getSubscriptionsOfUser(userEmail); |
|
| 241 |
} |
|
| 242 |
|
|
| 227 | 243 |
} |
Also available in: Unified diff
1. Properties file changes.
2. Aggregation details / aggregation object add.
3. Other changes from stef