Source file "org/springframework/kafka/requestreply/ReplyingKafkaTemplate.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 834 of 834 | 0% | 60 of 60 | 0% | 85 | 85 | 198 | 198 | 55 | 55 |
| ReplyingKafkaTemplate(ProducerFactory, GenericMessageListenerContainer, boolean) | | 0% | | 0% | 6 | 6 | 35 | 35 | 1 | 1 |
| sendAndReceive(ProducerRecord, Duration) | | 0% | | 0% | 6 | 6 | 23 | 23 | 1 | 1 |
| lambda$onMessage$9(ConsumerRecord) | | 0% | | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
| checkDeserialization(ConsumerRecord, LogAccessor) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| lambda$scheduleTimeout$6(CorrelationKey, ProducerRecord) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| start() | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| sendAndReceive(Message, Duration, ParameterizedTypeReference) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| defaultCorrelationIdStrategy(ProducerRecord) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$sendAndReceive$2(RequestReplyTypedMessageFuture, ParameterizedTypeReference, ConsumerRecord) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| checkForErrors(ConsumerRecord) | | 0% | | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
| lambda$checkDeserialization$11(ConsumerRecord) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$checkDeserialization$10(ConsumerRecord) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| logLateArrival(ConsumerRecord, CorrelationKey) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| setDefaultReplyTimeout(Duration) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$onMessage$7(ConsumerRecord) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| missingCorrelationLogMessage(ConsumerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| afterPropertiesSet() | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| lambda$onMessage$8(ConsumerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$scheduleTimeout$5(ProducerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$sendAndReceive$4(ProducerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| stop() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| scheduleTimeout(ProducerRecord, CorrelationKey, Duration) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setTaskScheduler(TaskScheduler) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| destroy() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| setCorrelationIdStrategy(Function) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setCorrelationHeaderName(String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setReplyTopicHeaderName(String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setReplyPartitionHeaderName(String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setReplyErrorChecker(Function) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| waitForAssignment(Duration) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sendAndReceive(Message) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sendAndReceive(Message, ParameterizedTypeReference) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| ReplyingKafkaTemplate(ProducerFactory, GenericMessageListenerContainer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| sendAndReceive(Message, Duration) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sendAndReceive(ProducerRecord) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| stop(Runnable) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| isPending(CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| onMessage(List) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$logLateArrival$13(ConsumerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$logLateArrival$12(ConsumerRecord, CorrelationKey) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$sendAndReceive$3(RequestReplyTypedMessageFuture, Throwable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| setPhase(int) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| setAutoStartup(boolean) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| getAssignedReplyTopicPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| setSharedReplyTopic(boolean) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| onFirstPoll() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| static {...} | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getDefaultReplyTimeout() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isRunning() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getPhase() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isAutoStartup() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getCorrelationHeaderName() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| handleTimeout(CorrelationKey, RequestReplyFuture) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$new$1() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$new$0(ConsumerRecord) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |