MCPcopy Create free account

hub / github.com/TechniXC/transactions-locks-app / functions

Functions21 in github.com/TechniXC/transactions-locks-app

⨍ Functions 21◇ Types & classes 20
↓ 5 callersMethodaddLikesToSpeaker
Method for adding likes to speaker by ID or TalkName. @param likes DTO with information about likes to be added.
src/main/java/ru/jpoint/transactionslocksapp/service/SpeakerService.java:26
↓ 3 callersMethodsaveMessageToHistory
Method for saving message to history. Produces the message with DTO to kafka, for future processing. @param likes DTO with information about likes to
src/main/java/ru/jpoint/transactionslocksapp/service/SpeakerService.java:59
↓ 2 callersMethodprocessOneMessage
(Likes likes)
src/main/java/ru/jpoint/transactionslocksapp/messaging/SpeakerMessageProcessor.java:22
↓ 1 callersMethodfindByTalkName
(String talkName)
src/main/java/ru/jpoint/transactionslocksapp/repository/SpeakersRepository.java:17
Methodaccept
(Likes likes)
src/main/java/ru/jpoint/transactionslocksapp/messaging/LikesConsumer.java:23
MethodcontextLoads
()
src/test/java/ru/jpoint/transactionslocksapp/AbstractIntegrationTest.java:42
MethodcreateTaskToAddLikes
Method for creating task to add likes to speaker. Produces the message with DTO to kafka, for future processing. @param likes DTO with information ab
src/main/java/ru/jpoint/transactionslocksapp/service/SpeakerService.java:49
Methodcustomizer
()
src/main/java/ru/jpoint/transactionslocksapp/messaging/LikesConsumer.java:29
MethoddataSource
()
src/test/java/ru/jpoint/transactionslocksapp/AbstractIntegrationTest.java:52
MethoddoInTransactionWithoutResult
(TransactionStatus status)
src/main/java/ru/jpoint/transactionslocksapp/controller/TestPoolController.java:51
MethodlikesConsumer
()
src/main/java/ru/jpoint/transactionslocksapp/messaging/StreamsConfig.java:20
Methodmain
(String[] args)
src/main/java/ru/jpoint/transactionslocksapp/TransactionsLocksAppApplication.java:11
MethodprocessBatchOfMessages
(List<Likes> likes)
src/main/java/ru/jpoint/transactionslocksapp/messaging/SpeakerMessageProcessor.java:27
Methodredis
()
src/test/java/ru/jpoint/transactionslocksapp/AbstractIntegrationTest.java:64
MethodredisTemplate
(RedisConnectionFactory connectionFactory)
src/main/java/ru/jpoint/transactionslocksapp/config/RedisConfig.java:11
MethodreleaseLock
(String id)
src/main/java/ru/jpoint/transactionslocksapp/config/RedisLockProvider.java:26
MethodsaveMessageToHistory
Method for saving message to history. Produces the message with DTO to kafka, for future processing. @param likes DTO with information about likes to
src/main/java/ru/jpoint/transactionslocksapp/service/HistoryService.java:23
MethodtestTransaction
()
src/main/java/ru/jpoint/transactionslocksapp/controller/TestPoolController.java:22
MethodtryToAcquireLock
(String id, Duration ttl)
src/main/java/ru/jpoint/transactionslocksapp/config/RedisLockProvider.java:22
MethodupdateSpeaker
(@RequestBody Likes likes)
src/main/java/ru/jpoint/transactionslocksapp/controller/SpeakerController.java:21
MethodusingTransactionTemplate
()
src/main/java/ru/jpoint/transactionslocksapp/controller/TestPoolController.java:36