MCPcopy Create free account

hub / github.com/HasonHuang/distributed-transaction-process / functions

Functions684 in github.com/HasonHuang/distributed-transaction-process

↓ 1 callersMethoddoCreate
创建事务日志记录 @param transaction @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:146
↓ 1 callersMethoddoDelete
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:150
↓ 1 callersMethoddoFind
(List<Xid> xids)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:247
↓ 1 callersMethoddoFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:123
↓ 1 callersMethoddoFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/RedisTransactionRepository.java:144
↓ 1 callersMethoddoFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:100
↓ 1 callersMethoddoFindAllUnmodifiedSince
(Date date)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:154
↓ 1 callersMethoddoFindOne
(Xid xid)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:152
↓ 1 callersMethoddoInJedis
(Jedis jedis)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/JedisCallback.java:11
↓ 1 callersMethoddoUpdate
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:148
↓ 1 callersMethodfactoryOf
获取 Class 对象的单例工厂 @param clazz Class 对象 @param <T> Class 的类型 @return 单例工厂
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/FactoryBuilder.java:32
↓ 1 callersMethodfindAllUnmodifiedSince
找出所有未处理事务日志(从某一时间点开始). @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:44
↓ 1 callersMethodfindByConsumerQueueAndDead
根据消息队列和死亡状态,分页获取数据 @param consumerQueue 消息队列 @param dead 是否死亡 @param page 分页参数 @return list
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/dao/MessageRepository.java:39
↓ 1 callersMethodfindByMessageId
根据消息ID,获取记录 @param messageId 消息ID @return Message
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/dao/MessageRepository.java:29
↓ 1 callersMethodfindByXid
根据xid查找事务日志记录. @param xid @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:38
↓ 1 callersMethodfindFromCache
从缓存中查找. @param transactionXid @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:133
↓ 1 callersMethodfromJson
反序列化POJO或简单Collection如List<String>. 如果JSON字符串为Null或"null"字符串, 返回Null. 如果JSON字符串为"[]", 返回空集合. 如需反序列化复杂Collection如List<MyBean>, 请使用fromJson(String, Ja
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:104
↓ 1 callersMethodgenerateAndEnlistConsumerParticipant
生成并登记消费者的参与者 @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:128
↓ 1 callersMethodgenerateAndEnlistProviderParticipant
生成并登记服务提供者的参与者 @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:182
↓ 1 callersMethodgenerateAndEnlistRootParticipant
生成和登记根参与者. @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:83
↓ 1 callersMethodgetAmont
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:20
↓ 1 callersMethodgetBalance
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:79
↓ 1 callersMethodgetBalanceAmount
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:45
↓ 1 callersMethodgetByMessageId
根据消息ID获取消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:54
↓ 1 callersMethodgetCreateTime
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:97
↓ 1 callersMethodgetCreateTime
()
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:78
↓ 1 callersMethodgetCronExpression
获取定时任务规则表达式. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:26
↓ 1 callersMethodgetDriverClassName
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:45
↓ 1 callersMethodgetDriverClassName
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:45
↓ 1 callersMethodgetDriverClassName
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:45
↓ 1 callersMethodgetDuration
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:43
↓ 1 callersMethodgetEditTime
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:152
↓ 1 callersMethodgetExpire
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:60
↓ 1 callersMethodgetField1
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:160
↓ 1 callersMethodgetInnerMap
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:47
↓ 1 callersMethodgetLocale
()
ms-core/src/main/java/com/hason/dtp/core/utils/LocaleUtils.java:24
↓ 1 callersMethodgetMapKey
(String prefixName)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:376
↓ 1 callersMethodgetMaxRetryCount
获取最大重试次数 @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:14
↓ 1 callersMethodgetMessageBody
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:80
↓ 1 callersMethodgetMessageId
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:17
↓ 1 callersMethodgetNullValue
(Class type)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/ReflectionUtils.java:42
↓ 1 callersMethodgetPassword
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:70
↓ 1 callersMethodgetPassword
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:69
↓ 1 callersMethodgetPassword
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:69
↓ 1 callersMethodgetRecoverDuration
获取需要执行事务恢复的持续时间. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:20
↓ 1 callersMethodgetRequestInfo1
(NativeWebRequest webRequest)
ms-core/src/main/java/com/hason/dtp/core/support/HandlerMethodMultiArgumentResolver.java:86
↓ 1 callersMethodgetRequestValueForAttribute
Obtain a value from the request that may be used to instantiate the model attribute through type conversion from String to the target type. <p>The def
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:160
↓ 1 callersMethodgetTransactionContextParamPosition
获取事务上下文参数的位置. @param parameterTypes @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/CompensableMethodUtils.java:43
↓ 1 callersMethodgetType
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:77
↓ 1 callersMethodgetType
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:77
↓ 1 callersMethodgetType
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:77
↓ 1 callersMethodgetUrl
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:53
↓ 1 callersMethodgetUrl
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:53
↓ 1 callersMethodgetUrl
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:53
↓ 1 callersMethodgetUserId
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:25
↓ 1 callersMethodgetUserPointQueue
()
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/config/properties/QueueMessageProperties.java:23
↓ 1 callersMethodhandleSendingTimeout
处理状态为“发送中”且已超时的消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageStatusService.java:20
↓ 1 callersMethodhandleWaitConfirmTimeout
处理状态为“待确认”且已超时的消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageStatusService.java:15
↓ 1 callersMethodincr
(TCC-try) 增加积分 @param context 事务上下文 @param userId 用户ID @param increment 增量
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/service/PointService.java:51
↓ 1 callersMethodjsr310
()
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:177
↓ 1 callersMethodloadErrorTransactions
找出所有执行错误的事务信息 @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/TransactionRecovery.java:50
↓ 1 callersMethodmakeDirIfNecessory
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:118
↓ 1 callersMethodprepareServletRequest
(Object target, NativeWebRequest request, MethodParameter parameter)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:407
↓ 1 callersMethodpropagationNewBegin
基于全局事务ID扩展创建新的分支事务,并存于当前线程的事务局部变量中. @param transactionContext
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:49
↓ 1 callersMethodproviderMethodProceed
服务提供者事务方法处理. @param pjp @param transactionContext @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:102
↓ 1 callersMethodreSendAllDeadByQueueName
重发某个消息队列中的全部已死亡的消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:64
↓ 1 callersMethodreSendByMessageId
根据messageId重发某条消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:44
↓ 1 callersMethodreSendNoDead
重发消息并更新数据库记录,不设置死亡状态 @param messages 消息列表
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:181
↓ 1 callersMethodrecharge
(TCC-try) 用户充值 @param context 事务上下文 @param order 资金账户订单 @return CapitalAccount
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/CapitalAccountService.java:52
↓ 1 callersMethodrecoverErrorTransactions
恢复错误的事务. @param transactions
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/TransactionRecovery.java:82
↓ 1 callersMethodregisterMessage
生成注册赠送积分的消息 @param user 用户 @return Message
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:74
↓ 1 callersMethodremove
(Object key)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:95
↓ 1 callersMethodremoveFromCache
从缓存中删除. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:124
↓ 1 callersMethodrollback
事务回滚(包含此事务的所有参与者的逐个回滚,在TransactionManager中被调用).
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:143
↓ 1 callersMethodrootMethodProceed
主事务方法的处理. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:69
↓ 1 callersMethodsave
(User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:89
↓ 1 callersMethodsave
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserServiceImpl.java:99
↓ 1 callersMethodsaveAndSend
存储并发送消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:29
↓ 1 callersMethodsaveAndSendMessage
存储并发送消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:35
↓ 1 callersMethodsetAmont
(BigDecimal amont)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:24
↓ 1 callersMethodsetAmount
(BigDecimal amount)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:73
↓ 1 callersMethodsetCreateTime
(LocalDateTime createTime)
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:82
↓ 1 callersMethodsetCronExpression
(String cronExpression)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/recover/DefaultRecoverConfig.java:53
↓ 1 callersMethodsetInnerMap
(Map<K, V> innerMap)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:43
↓ 1 callersMethodsetMerchantOrderNo
(String merchantOrderNo)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:65
↓ 1 callersMethodsetMessageId
(String messageId)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:21
↓ 1 callersMethodsetModifiedTime
(LocalDateTime modifiedTime)
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:90
↓ 1 callersMethodsetPassword
(String password)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:74
↓ 1 callersMethodsetUserId
(Long userId)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:29
↓ 1 callersMethodsetUserId
(Long userId)
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/entity/Point.java:48
↓ 1 callersMethodsetUserId
(Long userId)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:57
↓ 1 callersMethodsetUserId
(Long userId)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:57
↓ 1 callersMethodsetUsername
(String username)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:65
↓ 1 callersMethodsleep
(long timeout)
reliable-message-transaction/rm-account-web/src/test/java/com/hason/dtp/test/account/web/MockConcurrent.java:73
↓ 1 callersMethodtccDataSource
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/TccConfig.java:43
↓ 1 callersMethodtccDataSource
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/TccConfig.java:44
↓ 1 callersMethodtccDataSource
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/TccConfig.java:44
↓ 1 callersMethodtestSave
()
reliable-message-transaction/rm-message/src/test/java/com/hason/dtp/test/message/dao/MessageRepositoryTest.java:34
↓ 1 callersMethodtoString
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:34
↓ 1 callersMethodvalidateComponent
(WebDataBinder binder, MethodParameter parameter)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:479
← previousnext →201–300 of 684, ranked by callers