- PciRequestWrapper request = operation.makeRequest(1).getRight();
- assertEquals(Arrays.asList(request.getBody().getCommonHeader().getSubRequestId()),
- operation.getExpectedKeyValues(50, request));
+ operation.generateSubRequestId(1);
+
+ PciMessage request = operation.makeRequest(1);
+ assertEquals(List.of(request.getBody().getInput().getCommonHeader().getSubRequestId()),
+ operation.getExpectedKeyValues(50, request));
+ }
+
+ /**
+ * Tests "success" case with simulator.
+ */
+ @Test
+ public void testSuccess() throws Exception {
+ BidirectionalTopicParams opParams =
+ BidirectionalTopicParams.builder().sinkTopic(MY_SINK).sourceTopic(MY_SOURCE).build();
+ config = new BidirectionalTopicConfig(blockingExecutor, opParams, topicMgr, SdnrOperation.SELECTOR_KEYS);