Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/HasonHuang/distributed-transaction-process
/ functions
Functions
684 in github.com/HasonHuang/distributed-transaction-process
⨍
Functions
684
◇
Types & classes
195
↓ 1 callers
Method
doCreate
创建事务日志记录 @param transaction @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:146
↓ 1 callers
Method
doDelete
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:150
↓ 1 callers
Method
doFind
(List<Xid> xids)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:247
↓ 1 callers
Method
doFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:123
↓ 1 callers
Method
doFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/RedisTransactionRepository.java:144
↓ 1 callers
Method
doFindAll
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:100
↓ 1 callers
Method
doFindAllUnmodifiedSince
(Date date)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:154
↓ 1 callers
Method
doFindOne
(Xid xid)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:152
↓ 1 callers
Method
doInJedis
(Jedis jedis)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/JedisCallback.java:11
↓ 1 callers
Method
doUpdate
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:148
↓ 1 callers
Method
factoryOf
获取 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 callers
Method
findAllUnmodifiedSince
找出所有未处理事务日志(从某一时间点开始). @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:44
↓ 1 callers
Method
findByConsumerQueueAndDead
根据消息队列和死亡状态,分页获取数据 @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 callers
Method
findByMessageId
根据消息ID,获取记录 @param messageId 消息ID @return Message
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/dao/MessageRepository.java:29
↓ 1 callers
Method
findByXid
根据xid查找事务日志记录. @param xid @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:38
↓ 1 callers
Method
findFromCache
从缓存中查找. @param transactionXid @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:133
↓ 1 callers
Method
fromJson
反序列化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 callers
Method
generateAndEnlistConsumerParticipant
生成并登记消费者的参与者 @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:128
↓ 1 callers
Method
generateAndEnlistProviderParticipant
生成并登记服务提供者的参与者 @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:182
↓ 1 callers
Method
generateAndEnlistRootParticipant
生成和登记根参与者. @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:83
↓ 1 callers
Method
getAmont
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:20
↓ 1 callers
Method
getBalance
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:79
↓ 1 callers
Method
getBalanceAmount
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:45
↓ 1 callers
Method
getByMessageId
根据消息ID获取消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:54
↓ 1 callers
Method
getCreateTime
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:97
↓ 1 callers
Method
getCreateTime
()
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:78
↓ 1 callers
Method
getCronExpression
获取定时任务规则表达式. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:26
↓ 1 callers
Method
getDriverClassName
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:45
↓ 1 callers
Method
getDriverClassName
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:45
↓ 1 callers
Method
getDriverClassName
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:45
↓ 1 callers
Method
getDuration
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:43
↓ 1 callers
Method
getEditTime
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:152
↓ 1 callers
Method
getExpire
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:60
↓ 1 callers
Method
getField1
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:160
↓ 1 callers
Method
getInnerMap
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:47
↓ 1 callers
Method
getLocale
()
ms-core/src/main/java/com/hason/dtp/core/utils/LocaleUtils.java:24
↓ 1 callers
Method
getMapKey
(String prefixName)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:376
↓ 1 callers
Method
getMaxRetryCount
获取最大重试次数 @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:14
↓ 1 callers
Method
getMessageBody
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:80
↓ 1 callers
Method
getMessageId
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:17
↓ 1 callers
Method
getNullValue
(Class type)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/ReflectionUtils.java:42
↓ 1 callers
Method
getPassword
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:70
↓ 1 callers
Method
getPassword
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:69
↓ 1 callers
Method
getPassword
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:69
↓ 1 callers
Method
getRecoverDuration
获取需要执行事务恢复的持续时间. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/RecoverConfig.java:20
↓ 1 callers
Method
getRequestInfo1
(NativeWebRequest webRequest)
ms-core/src/main/java/com/hason/dtp/core/support/HandlerMethodMultiArgumentResolver.java:86
↓ 1 callers
Method
getRequestValueForAttribute
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 callers
Method
getTransactionContextParamPosition
获取事务上下文参数的位置. @param parameterTypes @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/CompensableMethodUtils.java:43
↓ 1 callers
Method
getType
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:77
↓ 1 callers
Method
getType
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:77
↓ 1 callers
Method
getType
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:77
↓ 1 callers
Method
getUrl
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:53
↓ 1 callers
Method
getUrl
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:53
↓ 1 callers
Method
getUrl
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:53
↓ 1 callers
Method
getUserId
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:25
↓ 1 callers
Method
getUserPointQueue
()
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/config/properties/QueueMessageProperties.java:23
↓ 1 callers
Method
handleSendingTimeout
处理状态为“发送中”且已超时的消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageStatusService.java:20
↓ 1 callers
Method
handleWaitConfirmTimeout
处理状态为“待确认”且已超时的消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageStatusService.java:15
↓ 1 callers
Method
incr
(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 callers
Method
jsr310
()
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:177
↓ 1 callers
Method
loadErrorTransactions
找出所有执行错误的事务信息 @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/TransactionRecovery.java:50
↓ 1 callers
Method
makeDirIfNecessory
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/FileSystemTransactionRepository.java:118
↓ 1 callers
Method
prepareServletRequest
(Object target, NativeWebRequest request, MethodParameter parameter)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:407
↓ 1 callers
Method
propagationNewBegin
基于全局事务ID扩展创建新的分支事务,并存于当前线程的事务局部变量中. @param transactionContext
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:49
↓ 1 callers
Method
providerMethodProceed
服务提供者事务方法处理. @param pjp @param transactionContext @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:102
↓ 1 callers
Method
reSendAllDeadByQueueName
重发某个消息队列中的全部已死亡的消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:64
↓ 1 callers
Method
reSendByMessageId
根据messageId重发某条消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:44
↓ 1 callers
Method
reSendNoDead
重发消息并更新数据库记录,不设置死亡状态 @param messages 消息列表
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:181
↓ 1 callers
Method
recharge
(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 callers
Method
recoverErrorTransactions
恢复错误的事务. @param transactions
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/recover/TransactionRecovery.java:82
↓ 1 callers
Method
registerMessage
生成注册赠送积分的消息 @param user 用户 @return Message
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:74
↓ 1 callers
Method
remove
(Object key)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:95
↓ 1 callers
Method
removeFromCache
从缓存中删除. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:124
↓ 1 callers
Method
rollback
事务回滚(包含此事务的所有参与者的逐个回滚,在TransactionManager中被调用).
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:143
↓ 1 callers
Method
rootMethodProceed
主事务方法的处理. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:69
↓ 1 callers
Method
save
(User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:89
↓ 1 callers
Method
save
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserServiceImpl.java:99
↓ 1 callers
Method
saveAndSend
存储并发送消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:29
↓ 1 callers
Method
saveAndSendMessage
存储并发送消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:35
↓ 1 callers
Method
setAmont
(BigDecimal amont)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:24
↓ 1 callers
Method
setAmount
(BigDecimal amount)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:73
↓ 1 callers
Method
setCreateTime
(LocalDateTime createTime)
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:82
↓ 1 callers
Method
setCronExpression
(String cronExpression)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/recover/DefaultRecoverConfig.java:53
↓ 1 callers
Method
setInnerMap
(Map<K, V> innerMap)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:43
↓ 1 callers
Method
setMerchantOrderNo
(String merchantOrderNo)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:65
↓ 1 callers
Method
setMessageId
(String messageId)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:21
↓ 1 callers
Method
setModifiedTime
(LocalDateTime modifiedTime)
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/entity/User.java:90
↓ 1 callers
Method
setPassword
(String password)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:74
↓ 1 callers
Method
setUserId
(Long userId)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/payload/RegistPoint.java:29
↓ 1 callers
Method
setUserId
(Long userId)
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/entity/Point.java:48
↓ 1 callers
Method
setUserId
(Long userId)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:57
↓ 1 callers
Method
setUserId
(Long userId)
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalAccount.java:57
↓ 1 callers
Method
setUsername
(String username)
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:65
↓ 1 callers
Method
sleep
(long timeout)
reliable-message-transaction/rm-account-web/src/test/java/com/hason/dtp/test/account/web/MockConcurrent.java:73
↓ 1 callers
Method
tccDataSource
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/TccConfig.java:43
↓ 1 callers
Method
tccDataSource
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/TccConfig.java:44
↓ 1 callers
Method
tccDataSource
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/TccConfig.java:44
↓ 1 callers
Method
testSave
()
reliable-message-transaction/rm-message/src/test/java/com/hason/dtp/test/message/dao/MessageRepositoryTest.java:34
↓ 1 callers
Method
toString
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:34
↓ 1 callers
Method
validateComponent
(WebDataBinder binder, MethodParameter parameter)
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:479
← previous
next →
201–300 of 684, ranked by callers