MCPcopy Create free account

hub / github.com/callistaenterprise/blog-synchronous-kafka / functions

Functions83 in github.com/callistaenterprise/blog-synchronous-kafka

⨍ Functions 83◇ Types & classes 19
↓ 8 callersMethodadapt
(RequestReplyFuture<K, V, R> requestReplyFuture)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:63
↓ 5 callersMethoddoSendAndReceive
(ProducerRecord<K, V> record)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:96
↓ 5 callersMethodsendAndReceive
(String topic, V data)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaOperations.java:16
↓ 5 callersMethodtoIndentedString
Convert the given object to string with each line indented by 4 spaces (except the first line).
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:162
↓ 4 callersMethodsendAndReceive
(String topic, @Nullable V data)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:67
↓ 4 callersMethodsendAndReceiveDefault
(V data)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaOperations.java:8
↓ 2 callersMethodconsumerConfigs
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:46
↓ 2 callersMethodgetCar
(String vin)
car/src/main/java/se/callista/blog/synch_kafka/car/persist/CarRepository.java:7
↓ 2 callersMethodgetMessage
The message itself @return message
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:95
↓ 2 callersMethodproducerConfigs
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:56
↓ 2 callersMethodtoString
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:144
↓ 1 callersMethodconsumerConfigs
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:48
↓ 1 callersMethoderror
(String error)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:69
↓ 1 callersMethodgetCarAsync
(String vin)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/car/CarFacade.java:11
↓ 1 callersMethodgetCarAsync
(String vin)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/car/CarFacadeImpl.java:32
↓ 1 callersMethodgetFirstAssignedReplyTopicPartition
()
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:29
↓ 1 callersMethodgetStatus
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ApiException.java:24
↓ 1 callersMethodgetTimestamp
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ApiException.java:20
↓ 1 callersMethodintToBytesBigEndian
(final int data)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:42
↓ 1 callersMethodmessage
(String message)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:86
↓ 1 callersMethodpath
(String path)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:105
↓ 1 callersMethodproducerConfigs
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:59
↓ 1 callersMethodreplyConsumerFactory
()
car/src/test/java/se/callista/blog/synch_kafka/car/conf/CompletableFutureReplyingKafkaTemplateConfig.java:48
↓ 1 callersMethodreplyConsumerFactory
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:84
↓ 1 callersMethodreplyListenerContainer
()
car/src/test/java/se/callista/blog/synch_kafka/car/conf/CompletableFutureReplyingKafkaTemplateConfig.java:56
↓ 1 callersMethodreplyListenerContainer
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:92
↓ 1 callersMethodreplyProducerFactory
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:80
↓ 1 callersMethodreplyTemplate
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:85
↓ 1 callersMethodrequestConsumerFactory
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:65
↓ 1 callersMethodrequestProducerFactory
()
car/src/test/java/se/callista/blog/synch_kafka/car/conf/CompletableFutureReplyingKafkaTemplateConfig.java:43
↓ 1 callersMethodrequestProducerFactory
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:79
↓ 1 callersMethodrequestReply
(String topic, V value)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaOperations.java:15
↓ 1 callersMethodrequestReplyDefault
(V value)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaOperations.java:7
↓ 1 callersMethodstatus
(Integer status)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:51
↓ 1 callersMethodtimestamp
(OffsetDateTime timestamp)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:32
↓ 1 callersMethodtoString
()
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:32
MethodApiException
(HttpStatus status, String msg)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ApiException.java:14
MethodCar
()
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:8
MethodCompletableFutureReplyingKafkaTemplate
(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:18
MethodPartitionAwareReplyingKafkaTemplate
(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:24
Methodadmin
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:95
Methodadmin
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:98
Methodcancel
(boolean mayInterruptIfRunning)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:65
MethodcarController
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:90
Methodequals
(Object obj)
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:46
Methodequals
(java.lang.Object o)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:123
MethodgetCar
(String vin)
car/src/main/java/se/callista/blog/synch_kafka/car/persist/CarRepositoryImpl.java:20
MethodgetCar
(@PathVariable("vin") String vin)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/CarController.java:27
MethodgetCar
(String vin)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/car/CarFacade.java:9
MethodgetCar
(String vin)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/car/CarFacadeImpl.java:22
MethodgetError
http status string @return error
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:78
MethodgetPath
Uri path to the failing operation @return path
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:114
MethodgetRegNo
()
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:24
MethodgetStatus
http status code @return status
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:60
MethodgetTimestamp
Timestamp for when the error occured @return timestamp
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:41
MethodgetVin
()
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:16
MethodhandleApiException
(ApiException ex, WebRequest request)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/CarController.java:42
MethodhashCode
()
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:37
MethodhashCode
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:139
MethodinitCars
()
car/src/main/java/se/callista/blog/synch_kafka/car/persist/CarRepositoryImpl.java:14
Methodmain
(String[] args)
car/src/main/java/se/callista/blog/synch_kafka/car/CarApplication.java:9
Methodmain
(String[] args)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/CarClientApplication.java:9
MethodonFailure
(Throwable t)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:78
MethodonSuccess
(SendResult<K, V> sendResult)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:74
Methodreceive
(String vin)
car/src/main/java/se/callista/blog/synch_kafka/car/controller/CarController.java:18
MethodreplyKafkaTemplate
()
car/src/test/java/se/callista/blog/synch_kafka/car/conf/CompletableFutureReplyingKafkaTemplateConfig.java:34
MethodreplyKafkaTemplate
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:69
MethodreplyTopic
()
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/conf/KafkaConfig.java:105
MethodrequestReply
(String topic, V value)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:43
MethodrequestReplyDefault
(V value)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/CompletableFutureReplyingKafkaTemplate.java:23
MethodrequestReplyListenerContainerFactory
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:71
MethodrequestTopic
()
car/src/main/java/se/callista/blog/synch_kafka/car/conf/KafkaConfig.java:102
MethodsendAndReceiveDefault
(@Nullable V data)
kafka-request-reply-util/src/main/java/se/callista/blog/synch_kafka/request_reply_util/PartitionAwareReplyingKafkaTemplate.java:47
MethodsetError
(String error)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:82
MethodsetMessage
(String message)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:101
MethodsetPath
(String path)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:118
MethodsetRegNo
(String regNo)
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:28
MethodsetStatus
(Integer status)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:65
MethodsetTimestamp
(OffsetDateTime timestamp)
car-client/src/main/java/se/callista/blog/synch_kafka/car/client/controller/ErrorMessage.java:47
MethodsetUp
()
car/src/test/java/se/callista/blog/synch_kafka/car/controller/CarControllerTest.java:44
MethodsetUpBeforeClass
()
car/src/test/java/se/callista/blog/synch_kafka/car/controller/CarControllerTest.java:39
MethodsetVin
(String vIN)
car-model/src/main/java/se/callista/blog/synch_kafka/car/model/Car.java:20
MethodtestRequestResponse
()
car/src/test/java/se/callista/blog/synch_kafka/car/controller/CarControllerTest.java:54