Functions — github.com/dilipsundarraj1/kafka-for-developers-using-spring-boot

hub / github.com/dilipsundarraj1/kafka-for-developers-using-spring-boot / functions

Functions59 in github.com/dilipsundarraj1/kafka-for-developers-using-spring-boot

⨍ Functions 59 ◇ Types & classes 29

↓ 10 callersMethodprocessLibraryEvent

(ConsumerRecord<Integer,String> consumerRecord)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:32

↓ 8 callersMethodsendLibraryEvent_Approach2

(LibraryEvent libraryEvent)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:52

↓ 6 callersMethodonMessage

(ConsumerRecord<Integer, String> consumerRecord)

library-events-consumer/src/main/java/com/learnkafka/consumer/LibraryEventsConsumer.java:20

↓ 4 callersMethodsave

(LibraryEvent libraryEvent)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:67

↓ 2 callersMethodfindAllByStatus

(String status)

library-events-consumer/src/main/java/com/learnkafka/jpa/FailureRecordRepository.java:10

↓ 2 callersMethodhandleFailure

(Integer key, String value, Throwable ex)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:104

↓ 2 callersMethodhandleSuccess

(Integer key, String value, SendResult<Integer, String> result)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:115

↓ 1 callersMethodbuildConsumerRecord

(FailureRecord failureRecord)

library-events-consumer/src/main/java/com/learnkafka/scheduler/RetryScheduler.java:49

↓ 1 callersMethodbuildProducerRecord

(Integer key, String value, String topic)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:76

↓ 1 callersMethoderrorHandler

()

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfig.java:85

↓ 1 callersMethodhandleFailure

(Integer key, String value, Throwable ex)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:92

↓ 1 callersMethodhandleRecovery

(ConsumerRecord<Integer,String> record)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:73

↓ 1 callersMethodhandleSuccess

(Integer key, String value, SendResult<Integer, String> result)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:101

↓ 1 callersMethodpublishingRecoverer

()

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfig.java:55

↓ 1 callersMethodretryTemplate

()

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfigLegacy.java:112

↓ 1 callersMethodsimpleRetryPolicy

()

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfigLegacy.java:122

↓ 1 callersMethodvalidate

(LibraryEvent libraryEvent)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:55

MethodFailureService

(FailureRecordRepository failureRecordRepository)

library-events-consumer/src/main/java/com/learnkafka/service/FailureService.java:14

MethodfindAllByStatus

()

library-events-consumer/src/test/java/intg/com/learnkafka/jpa/FailureRecordRepositoryTest.java:35

MethodhandleRequestBody

(MethodArgumentNotValidException ex)

library-events-producer/src/main/java/com/learnkafka/controller/LibraryEventControllerAdvice.java:19

MethodkafkaListenerContainerFactory

( ConcurrentKafkaListenerContainerFactoryConfigurer configurer, ObjectProvider<Consume

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfigLegacy.java:38

MethodkafkaListenerContainerFactory

( ConcurrentKafkaListenerContainerFactoryConfigurer configurer, ObjectProvider<Consume

library-events-consumer/src/main/java/com/learnkafka/config/LibraryEventsConsumerConfig.java:125

MethodlibraryEvents

()

library-events-producer/src/main/java/com/learnkafka/config/AutoCreateConfig.java:18

Methodmain

(String[] args)

library-events-producer/src/main/java/com/learnkafka/LibraryEventsProducerApplication.java:9

Methodmain

(String[] args)

library-events-consumer/src/main/java/com/learnkafka/LibraryEventsConsumerApplication.java:11

MethodonFailure

(Throwable ex)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:40

MethodonFailure

(Throwable ex)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:80

MethodonMessage

(ConsumerRecord<Integer,String> consumerRecord)

library-events-consumer/src/main/java/com/learnkafka/consumer/LibraryEventsRetryConsumer.java:18

MethodonMessage

(ConsumerRecord<Integer, String> consumerRecord, Acknowledgment acknowledgment)

library-events-consumer/src/main/java/com/learnkafka/consumer/LibraryEventsConsumerManualOffset.java:14

MethodonSuccess

(SendResult<Integer, String> result)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:45

MethodonSuccess

(SendResult<Integer, String> result)

library-events-consumer/src/main/java/com/learnkafka/service/LibraryEventsService.java:85

MethodpostLibraryEvent

()

library-events-producer/src/test/java/unit/com/learnkafka/controller/LibraryEventControllerUnitTest.java:37

MethodpostLibraryEvent

()

library-events-producer/src/test/java/intg/com/learnkafka/controller/LibraryEventsControllerIntegrationTest.java:57

MethodpostLibraryEvent

(@RequestBody @Valid LibraryEvent libraryEvent)

library-events-producer/src/main/java/com/learnkafka/controller/LibraryEventsController.java:27

MethodpostLibraryEvent_4xx

()

library-events-producer/src/test/java/unit/com/learnkafka/controller/LibraryEventControllerUnitTest.java:62

MethodpublishModifyLibraryEvent_999_LibraryEventId

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:237

MethodpublishModifyLibraryEvent_999_LibraryEventId_deadletterTopic

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:252

MethodpublishModifyLibraryEvent_999_LibraryEventId_failureRecord

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:287

MethodpublishModifyLibraryEvent_Not_A_Valid_LibraryEventId

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:168

MethodpublishModifyLibraryEvent_Null_LibraryEventId

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:203

MethodpublishNewLibraryEvent

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:118

MethodpublishUpdateLibraryEvent

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:141

MethodputLibraryEvent

()

library-events-producer/src/test/java/intg/com/learnkafka/controller/LibraryEventsControllerIntegrationTest.java:95

MethodputLibraryEvent

(@RequestBody @Valid LibraryEvent libraryEvent)

library-events-producer/src/main/java/com/learnkafka/controller/LibraryEventsController.java:38

MethodretryFailedRecords

()

library-events-consumer/src/test/java/intg/com/learnkafka/scheduler/RetrySchedulerIntegrationTest.java:50

MethodretryFailedRecords

()

library-events-consumer/src/main/java/com/learnkafka/scheduler/RetryScheduler.java:28

MethodsaveFailedRecord

(ConsumerRecord<Integer, String> record, Exception exception, String recordStatus)

library-events-consumer/src/main/java/com/learnkafka/service/FailureService.java:18

MethodsendLibraryEvent

(LibraryEvent libraryEvent)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:33

MethodsendLibraryEventSynchronous

(LibraryEvent libraryEvent)

library-events-producer/src/main/java/com/learnkafka/producer/LibraryEventProducer.java:85

MethodsendLibraryEvent_Approach2_failure

()

library-events-producer/src/test/java/unit/com/learnkafka/producer/LibraryEventProducerUnitTest.java:41

MethodsendLibraryEvent_Approach2_success

()

library-events-producer/src/test/java/unit/com/learnkafka/producer/LibraryEventProducerUnitTest.java:64

MethodsetUp

()

library-events-producer/src/test/java/intg/com/learnkafka/controller/LibraryEventsControllerIntegrationTest.java:44

MethodsetUp

()

library-events-consumer/src/test/java/intg/com/learnkafka/scheduler/RetrySchedulerIntegrationTest.java:35

MethodsetUp

()

library-events-consumer/src/test/java/intg/com/learnkafka/jpa/FailureRecordRepositoryTest.java:25

MethodsetUp

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:92

MethodtearDown

()

library-events-producer/src/test/java/intg/com/learnkafka/controller/LibraryEventsControllerIntegrationTest.java:52

MethodtearDown

()

library-events-consumer/src/test/java/intg/com/learnkafka/consumer/LibraryEventsConsumerIntegrationTest.java:110

MethodupdateLibraryEvent

()

library-events-producer/src/test/java/unit/com/learnkafka/controller/LibraryEventControllerUnitTest.java:89

MethodupdateLibraryEvent_withNullLibraryEventId

()

library-events-producer/src/test/java/unit/com/learnkafka/controller/LibraryEventControllerUnitTest.java:115