@Test public void processRecordsTest() throws InterruptedException, ExecutionException { when(messageWriter.writeProcessRecordsMessage(any(ProcessRecordsInput.class))).thenReturn(buildFuture(true)); when(messageReader.getNextMessageFromSTDOUT()).thenReturn(buildFuture( new StatusMessage("processRecords"), Message.class)); assertThat(protocol.processRecords(ProcessRecordsInput.builder().records(EMPTY_RECORD_LIST).build()), equalTo(true)); }
boolean processRecords(ProcessRecordsInput processRecordsInput) { Future<Boolean> writeFuture = messageWriter.writeProcessRecordsMessage(processRecordsInput); return waitForStatusMessage(ProcessRecordsMessage.ACTION, processRecordsInput.checkpointer(), writeFuture); }
MultiLangProtocol { boolean processRecords(ProcessRecordsInput processRecordsInput) { Future<Boolean> writeFuture = messageWriter.writeProcessRecordsMessage(processRecordsInput); return waitForStatusMessage(ProcessRecordsMessage.ACTION, processRecordsInput.checkpointer(), writeFuture); } }
MultiLangProtocol { boolean processRecords(ProcessRecordsInput processRecordsInput) { Future<Boolean> writeFuture = messageWriter.writeProcessRecordsMessage(processRecordsInput); return waitForStatusMessage(ProcessRecordsMessage.ACTION, processRecordsInput.checkpointer(), writeFuture); } MultiLangProtocol(MessageReader messageReader, MessageWriter messageWriter,
            InitializationInput initializationInput, MultiLangDaemonConfiguration configuration); }
MultiLangProtocol { boolean processRecords(ProcessRecordsInput processRecordsInput) { Future<Boolean> writeFuture = messageWriter.writeProcessRecordsMessage(processRecordsInput); return waitForStatusMessage(ProcessRecordsMessage.ACTION, processRecordsInput.checkpointer(), writeFuture); } MultiLangProtocol(MessageReader messageReader, MessageWriter messageWriter,
            InitializationInput initializationInput, MultiLangDaemonConfiguration configuration);  }
MultiLangProtocol { boolean processRecords(ProcessRecordsInput processRecordsInput) { Future<Boolean> writeFuture = messageWriter.writeProcessRecordsMessage(processRecordsInput); return waitForStatusMessage(ProcessRecordsMessage.ACTION, processRecordsInput.checkpointer(), writeFuture); } MultiLangProtocol(MessageReader messageReader, MessageWriter messageWriter,
            InitializationInput initializationInput, MultiLangDaemonConfiguration configuration);   }