MCPcopy Create free account

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

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

↓ 3 callersMethodgetFormatId
获取 XID 的格式标识符部分。
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:57
↓ 3 callersMethodgetFullFileName
(Xid xid)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:114
↓ 3 callersMethodgetMethodName
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/InvocationContext.java:40
↓ 3 callersMethodgetNewParameterName
(String parameterName, String modelPrefixName)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:445
↓ 3 callersMethodgetPoint
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:88
↓ 3 callersMethodgetRecoverConfig
获取事务恢复配置. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/TransactionConfigurator.java:30
↓ 3 callersMethodgetRetry
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:68
↓ 3 callersMethodgetUriTemplateVariables
(NativeWebRequest request)
ms-core/src/main/java/com/hason/dtp/core/support/BaseMethodArgumentResolver.java:78
↓ 3 callersMethodgetUsername
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:61
↓ 3 callersMethodgetUsername
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:61
↓ 3 callersMethodisBindExceptionRequired
Whether to raise a {@link org.springframework.validation.BindException} on bind or validation errors. The default implementation returns {@code true}
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:533
↓ 3 callersMethodkeySet
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:83
↓ 3 callersMethodlogError
(Exception ex)
ms-core/src/main/java/com/hason/dtp/core/exception/RestExceptionHandler.java:76
↓ 3 callersMethodrecharge
(CapitalOrder order)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/RechargeService.java:18
↓ 3 callersMethodresetRetriedCount
(int retriedCount)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:161
↓ 3 callersMethodrollback
回滚参与者事务(在Participant中调用).
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Terminator.java:56
↓ 3 callersMethodsaveWaitingConfirm
预存储消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:19
↓ 3 callersMethodsetCreateTime
(LocalDateTime createTime)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:148
↓ 3 callersMethodsetDataSource
(DataSource dataSource)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:55
↓ 3 callersMethodsetDomain
(String domain)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:39
↓ 3 callersMethodsetId
(String id)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:60
↓ 3 callersMethodsetLastUpdateTime
(Date date)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:185
↓ 3 callersMethodsetPoint
(Integer point)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:92
↓ 3 callersMethodsetSerializer
(ObjectSerializer serializer)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:51
↓ 3 callersMethodsetSource
(MessageSource source)
ms-core/src/main/java/com/hason/dtp/core/utils/CheckUtil.java:17
↓ 3 callersMethodsetTbSuffix
(String tbSuffix)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:47
↓ 3 callersMethodsetVersion
(long version)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:177
↓ 3 callersMethoduuidToByteArray
(UUID uuid)
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:127
↓ 3 callersMethodvalueOf
(int id)
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionStatus.java:35
↓ 2 callersMethodcalculateMethodType
计算方法类型. @param transactionContext @param isCompensable @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/CompensableMethodUtils.java:19
↓ 2 callersMethodcanHandle
判断是否可以处理消息 @param message 消息 @return true 可以处理, false 不能处理
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/RecoveryHandlerService.java:26
↓ 2 callersMethodcanRetry
消息能否重发 @param max 最大重发次数 @param current 当前是第几次重发 @return true 可以, false 不可以
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/util/MessageUtils.java:19
↓ 2 callersMethodclone
克隆事务ID.
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:87
↓ 2 callersMethodcreate
(TCC-try) 创建积分账户 @param context 事务上下文 @param user 用户 @return Point
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/service/PointService.java:23
↓ 2 callersMethodfindByUsername
根据用户名,查询记录 @param username 用户名 @return User
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/dao/UserRepository.java:21
↓ 2 callersMethodget
获取订单 @param id 订单ID @return CapitalOrder
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/OrderService.java:33
↓ 2 callersMethodget
获取用户 @param userId 用户id @return User
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserService.java:53
↓ 2 callersMethodget
(Long userId)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserServiceImpl.java:109
↓ 2 callersMethodgetCreateTime
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:189
↓ 2 callersMethodgetData
()
ms-core/src/main/java/com/hason/dtp/core/utils/result/Result.java:26
↓ 2 callersMethodgetDataSource
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:59
↓ 2 callersMethodgetHttpStatus
()
ms-core/src/main/java/com/hason/dtp/core/exception/ErrorCode.java:26
↓ 2 callersMethodgetId
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:56
↓ 2 callersMethodgetId
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:52
↓ 2 callersMethodgetId
()
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:54
↓ 2 callersMethodgetId
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:37
↓ 2 callersMethodgetInstance
如果 instance 为 null,根据类名在容器中查找实例,找到则保存到 instance @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/FactoryBuilder.java:91
↓ 2 callersMethodgetKeyValue
(JedisPool jedisPool, final byte[] key)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/RedisHelper.java:31
↓ 2 callersMethodgetLastExpireTime
获取消息目前已经过期的时间(时间 = 现在 - 生存时间) @return LocalDateTime
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageStatusServiceImpl.java:123
↓ 2 callersMethodgetMax
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:35
↓ 2 callersMethodgetPassword
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:69
↓ 2 callersMethodgetPrefixName
(String name)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:394
↓ 2 callersMethodgetStatus
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:77
↓ 2 callersMethodgetTargetClass
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/InvocationContext.java:36
↓ 2 callersMethodgetTransactionContextFromArgs
从参数获取事务上下文. @param args @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/CompensableMethodUtils.java:60
↓ 2 callersMethodgetUserPointQueue
()
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/config/properties/QueueMessageProperties.java:52
↓ 2 callersMethodgrowCollectionIfNecessary
(final Collection collection, final int index)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:367
↓ 2 callersMethodhandle
处理消息 @param message 消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/RecoveryHandlerService.java:33
↓ 2 callersMethodid
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:218
↓ 2 callersMethodillegalChar
(char ch)
ms-core/src/main/java/com/hason/dtp/core/support/BaseMethodArgumentResolver.java:73
↓ 2 callersMethodincr
增加用户积分 @param userId 用户ID @param entity 事务实体 @return {@code Result<?>}, 由于是异步确认,try 操作执行后返回的 Point 仍是旧值,所以就不返回了
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/api/PointApi.java:43
↓ 2 callersMethodinvoke
根据调用上下文,获取目标方法并执行方法调用. @param invocationContext @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Terminator.java:66
↓ 2 callersMethodisDead
判断消息是否满足死亡条件 @param message 消息 @return boolean
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:214
↓ 2 callersMethodisEmpty
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:79
↓ 2 callersMethodisFactoryOf
判断 Class 对象 是否存在于容器中 @param clazz Class 对象 @param <T> Class 的类型 @return true 存在,false 不存在
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/BeanFactory.java:27
↓ 2 callersMethodisFormModelAttribute
(String parameterName, String modelPrefixName)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:458
↓ 2 callersMethodisSimpleComponent
(String prefixName)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:390
↓ 2 callersMethodlongToBytes
(long l)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/ByteUtils.java:11
↓ 2 callersMethodpropagationExistBegin
找出存在的事务并处理. @param transactionContext @throws NoExistedTransactionException
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:65
↓ 2 callersMethodreSend
重发消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:39
↓ 2 callersMethodreadTransaction
(File file)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:174
↓ 2 callersMethodregister
注册用户 @param user 用户 @return {@code Result<User>}
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/api/UserApi.java:26
↓ 2 callersMethodregisterBeanFactory
把容器添加到 FactoryBuilder @param beanFactory
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/FactoryBuilder.java:59
↓ 2 callersMethodsave
保存用户 @param user 用户 @return User
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserService.java:45
↓ 2 callersMethodsetBalance
(BigDecimal balance)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:83
↓ 2 callersMethodsetBalanceAmount
(BigDecimal balanceAmount)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:49
↓ 2 callersMethodsetCreateTime
(LocalDateTime createTime)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:101
↓ 2 callersMethodsetData
(T data)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:32
↓ 2 callersMethodsetData
(T data)
ms-core/src/main/java/com/hason/dtp/core/utils/result/Result.java:30
↓ 2 callersMethodsetError
(ErrorResult error)
ms-core/src/main/java/com/hason/dtp/core/utils/result/Result.java:38
↓ 2 callersMethodsetField1
(String field1)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:164
↓ 2 callersMethodsetModifiedTime
(LocalDateTime modifiedTime)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:110
↓ 2 callersMethodsetStatus
(CapitalOrderStatus status)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:81
↓ 2 callersMethodsetToDead
将消息标记为死亡消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:49
↓ 2 callersMethodsetValue
(Long value)
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/entity/Point.java:56
↓ 2 callersMethodvalidateIfApplicable
Validate the model attribute if applicable. <p>The default implementation checks for {@code @javax.validation.Valid}. @param binder the DataBinder
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:515
↓ 2 callersMethodwriteFile
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:140
↓ 1 callersMethodaddRegistPoint
(幂等)为新注册用户增加积分 @param userId 用户ID @param add 增加的积分 @return User
reliable-message-transaction/rm-account-point/src/main/java/com/hason/dtp/account/point/service/PointService.java:19
↓ 1 callersMethodaddRegistPoint
注册成功后,赠送积分 @param userId 用户ID @return {@code Result<?>}
reliable-message-transaction/rm-account-point-api/src/main/java/com/hason/dtp/account/point/api/PointApi.java:26
↓ 1 callersMethodaddRetriedCount
重试次数+1
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:157
↓ 1 callersMethodbegin
事务开始(创建事务日志记录,并将该事务日志记录存入当前线程的事务局部变量中)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:36
↓ 1 callersMethodbindRequestParameters
{@inheritDoc} <p>Downcast {@link org.springframework.web.bind.WebDataBinder} to {@link org.springframework.web.bind.ServletRequestDataBinder} before b
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:209
↓ 1 callersMethodcalNextSendTime
计算出下一次发送的时间点 @param previous 上一次发送的时间 @param currentRetry 现在是第几次重发 @return 下一次发送的时间
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/AccountPointRecoveryHandlerService.java:81
↓ 1 callersMethodcanSend
是否可以发送消息 @param previous 上一次发送的时间 @param currentRetry 现在是第几次重发 @return true 可以, false 不可以
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/AccountPointRecoveryHandlerService.java:69
↓ 1 callersMethodclear
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:51
↓ 1 callersMethodcommit
事务提交(包含此事务的所有参与者的逐个提交,在TransactionManager中被调用).
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:133
↓ 1 callersMethodcreateAttribute
Extension point to create the model attribute if not found in the model. The default implementation uses the default constructor. @param attributeNam
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:123
↓ 1 callersMethodcreateAttributeFromRequestValue
Create a model attribute from a String request value (e.g. URI template variable, request parameter) using type conversion. <p>The default implementat
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:185
↓ 1 callersMethoddeleteMessageByMessageId
根据消息ID删除消息
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:73
↓ 1 callersMethoddirectSend
直接发送消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:34
← previousnext →101–200 of 684, ranked by callers