- networkTransaction = new NetworkTransactionImpl(new RequestProcessor(this.getDataBroker()));
- PceTestUtils.writeNetworkInDataStore(this.getDataBroker());
- pceSendingPceRPCs =
- new PceSendingPceRPCs(PceTestData.getPCE_test1_request_54(), networkTransaction);
+ 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);