Code Review
/
transportpce.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
GNPy client refactor
[transportpce.git]
/
lighty
/
src
/
main
/
java
/
io
/
lighty
/
controllers
/
tpce
/
module
/
TransportPCEImpl.java
diff --git
a/lighty/src/main/java/io/lighty/controllers/tpce/module/TransportPCEImpl.java
b/lighty/src/main/java/io/lighty/controllers/tpce/module/TransportPCEImpl.java
index fa368050309d9ba629b32025c5a614cd357ff197..fe1c59fa6c152f9bc100c09f1a632bedb9881c49 100644
(file)
--- a/
lighty/src/main/java/io/lighty/controllers/tpce/module/TransportPCEImpl.java
+++ b/
lighty/src/main/java/io/lighty/controllers/tpce/module/TransportPCEImpl.java
@@
-43,6
+43,8
@@
import org.opendaylight.transportpce.olm.power.PowerMgmt;
import org.opendaylight.transportpce.olm.power.PowerMgmtImpl;
import org.opendaylight.transportpce.olm.service.OlmPowerService;
import org.opendaylight.transportpce.olm.service.OlmPowerServiceImpl;
import org.opendaylight.transportpce.olm.power.PowerMgmtImpl;
import org.opendaylight.transportpce.olm.service.OlmPowerService;
import org.opendaylight.transportpce.olm.service.OlmPowerServiceImpl;
+import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyConsumer;
+import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyConsumerImpl;
import org.opendaylight.transportpce.pce.impl.PceProvider;
import org.opendaylight.transportpce.pce.service.PathComputationService;
import org.opendaylight.transportpce.pce.service.PathComputationServiceImpl;
import org.opendaylight.transportpce.pce.impl.PceProvider;
import org.opendaylight.transportpce.pce.service.PathComputationService;
import org.opendaylight.transportpce.pce.service.PathComputationServiceImpl;
@@
-105,10
+107,13
@@
public class TransportPCEImpl extends AbstractLightyModule implements TransportP
networkTransaction = new NetworkTransactionImpl(requestProcessor);
LOG.info("Creating PCE beans ...");
networkTransaction = new NetworkTransactionImpl(requestProcessor);
LOG.info("Creating PCE beans ...");
+ // TODO: pass those parameters through command line
+ GnpyConsumer gnpyConsumer = new GnpyConsumerImpl("http://127.0.0.1:8008",
+ "gnpy", "gnpy", lightyServices.getAdapterContext().currentSerializer());
PathComputationService pathComputationService = new PathComputationServiceImpl(
networkTransaction,
lightyServices.getBindingNotificationPublishService(),
PathComputationService pathComputationService = new PathComputationServiceImpl(
networkTransaction,
lightyServices.getBindingNotificationPublishService(),
- lightyServices.getAdapterContext().currentSerializer()
+ gnpyConsumer
);
pceProvider = new PceProvider(lightyServices.getRpcProviderService(), pathComputationService);
);
pceProvider = new PceProvider(lightyServices.getRpcProviderService(), pathComputationService);