Code Review
/
transportpce.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Remove pce-blueprint.xml file
[transportpce.git]
/
pce
/
src
/
main
/
java
/
org
/
opendaylight
/
transportpce
/
pce
/
impl
/
PceProvider.java
diff --git
a/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java
b/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java
index 9b25b17916cefabb61d4ea0340fe7f482fd7bf7d..bab1554114ad7fe1e80d1f2f4e90311a3a6464d6 100644
(file)
--- a/
pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java
+++ b/
pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java
@@
-9,8
+9,12
@@
package org.opendaylight.transportpce.pce.impl;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
import org.opendaylight.transportpce.pce.service.PathComputationService;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
import org.opendaylight.transportpce.pce.service.PathComputationService;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev2
0012
8.TransportpcePceService;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev2
2080
8.TransportpcePceService;
import org.opendaylight.yangtools.concepts.ObjectRegistration;
import org.opendaylight.yangtools.concepts.ObjectRegistration;
+import org.osgi.service.component.annotations.Activate;
+import org.osgi.service.component.annotations.Component;
+import org.osgi.service.component.annotations.Deactivate;
+import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@
-18,23
+22,18
@@
import org.slf4j.LoggerFactory;
* Class to register
* Pce Service & Notification.
*/
* Class to register
* Pce Service & Notification.
*/
+@Component
public class PceProvider {
private static final Logger LOG = LoggerFactory.getLogger(PceProvider.class);
private final RpcProviderService rpcService;
public class PceProvider {
private static final Logger LOG = LoggerFactory.getLogger(PceProvider.class);
private final RpcProviderService rpcService;
- private final PathComputationService pathComputationService;
private ObjectRegistration<PceServiceRPCImpl> rpcRegistration;
private ObjectRegistration<PceServiceRPCImpl> rpcRegistration;
- public PceProvider(RpcProviderService rpcProviderService, PathComputationService pathComputationService) {
+ @Activate
+ public PceProvider(@Reference RpcProviderService rpcProviderService,
+ @Reference PathComputationService pathComputationService) {
this.rpcService = rpcProviderService;
this.rpcService = rpcProviderService;
- this.pathComputationService = pathComputationService;
- }
-
- /*
- * Method called when the blueprint container is created.
- */
- public void init() {
LOG.info("PceProvider Session Initiated");
final PceServiceRPCImpl consumer = new PceServiceRPCImpl(pathComputationService);
rpcRegistration = rpcService.registerRpcImplementation(TransportpcePceService.class, consumer);
LOG.info("PceProvider Session Initiated");
final PceServiceRPCImpl consumer = new PceServiceRPCImpl(pathComputationService);
rpcRegistration = rpcService.registerRpcImplementation(TransportpcePceService.class, consumer);
@@
-43,9
+42,9
@@
public class PceProvider {
/*
* Method called when the blueprint container is destroyed.
*/
/*
* Method called when the blueprint container is destroyed.
*/
+ @Deactivate
public void close() {
LOG.info("PceProvider Closed");
rpcRegistration.close();
}
public void close() {
LOG.info("PceProvider Closed");
rpcRegistration.close();
}
-
}
}