- public void setUp() throws Exception {
-// PceTestUtils.writeTopologyIntoDataStore(
-// dataBroker, dataStoreContext, "./topologyData/basePceTopology.json");
- networkTransaction = new NetworkTransactionImpl(new RequestProcessor(dataBroker));
- pceSendingPceRPCs = new PceSendingPceRPCs();
- pceSendingPceRPCs =
- new PceSendingPceRPCs(PceTestData.getPCERequest(), networkTransaction
- );
+ public void setUp() {
+ this.dataBroker = getNewDataBroker();
+ networkTransaction = new NetworkTransactionImpl(new RequestProcessor(this.dataBroker));
+ PceTestUtils.writeNetworkInDataStore(this.dataBroker);
+ gnpyConsumer = new GnpyConsumerImpl("http://localhost:9998",
+ "mylogin", "mypassword", getDataStoreContextUtil().getBindingDOMCodecServices());
+ pceSendingPceRPCs = new PceSendingPceRPCs(PceTestData.getPCE_test1_request_54(),
+ networkTransaction, gnpyConsumer, portMapping);
+ mapping = new MappingBuilder().setLogicalConnectionPoint("logicalConnectionPoint").setPortQual("xpdr-client")
+ .build();
+ NodeInfo info = new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr).build();
+ Nodes node = new NodesBuilder().withKey(new NodesKey("node")).setNodeId("node").setNodeInfo(info).build();
+ when(portMapping.getMapping(anyString(), anyString())).thenReturn(mapping);
+ when(portMapping.getNode(anyString())).thenReturn(node);