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
Method
hashCode
()
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:99
Method
hashCode
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:75
Method
hello
()
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/HelloController.java:18
Method
incr
HTTP 需要多使用一个中间层调用远程服务,以便让事务拦截器记录参与者 @param context @param userId @param increment @return
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/client/proxy/PointServiceClientProxy.java:31
Method
incr
(@PathVariable("userId") Long userId, @RequestBody TransactionEntity<Long> entity)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/controller/PointController.java:37
Method
incr
(TransactionContext context, Long userId, Long increment)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/service/PointServiceImpl.java:65
Method
init
()
reliable-message-transaction/rm-account/src/test/java/com/hason/dtp/test/account/dao/UserRepositoryTest.java:30
Method
init
初始化方法,Spring启动时执行.
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/recover/RecoverScheduledJob.java:35
Method
interceptCompensableMethod
拦截补偿方法. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:44
Method
interceptCompensableMethod
定义环绕通知(在一个方法执行之前和执行之后运行,第一个参数必须是 ProceedingJoinPoint类型,pjp将包含切点拦截的方法的参数信息) @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccCompensableAspect.java:47
Method
interceptTransactionContextMethod
拦截事务上下文方法. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:45
Method
interceptTransactionContextMethod
定义环绕通知(在一个方法执行之前和执行之后运行,第一个参数必须是 ProceedingJoinPoint类型,方法的调用者得到的返回值就是环绕通知返回的值) @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccTransactionContextAspect.java:47
Method
isEmpty
()
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:566
Method
isFactoryOf
(Class clazz)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringBeanFactory.java:27
Method
level
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/FeignConfig.java:17
Method
level
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/FeignConfig.java:18
Method
main
(String[] args)
reliable-message-transaction/rm-account-point/src/main/java/com/hason/dtp/account/point/RmAccountPointApplication.java:22
Method
main
(String[] args)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/RmMessageApplication.java:22
Method
main
(String[] args)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/RmAccountApplication.java:20
Method
main
(String[] args)
reliable-message-transaction/rm-account-web/src/test/java/com/hason/dtp/test/account/web/MockConcurrent.java:29
Method
main
(String[] args)
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/RmAccountWebApplication.java:20
Method
main
(String[] args)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/RmMessageConsumerApplication.java:20
Method
main
(String[] args)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/TccCapitalApplication.java:20
Method
main
(String[] args)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/TccAccountApplication.java:20
Method
main
测试用: @param args
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:146
Method
main
(String[] args)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/TccIntegralApplication.java:18
Method
main
(String[] args)
ms-discovery-eureka/src/main/java/com/hason/dtp/discovery/DiscoveryApplication.java:18
Method
methodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-account-point/src/main/java/com/hason/dtp/account/point/config/UtilConfig.java:19
Method
methodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/UtilConfig.java:20
Method
methodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/config/UtilConfig.java:19
Method
methodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/UtilConfig.java:18
Method
methodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/UtilConfig.java:18
Method
methodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/UtilConfig.java:18
Method
nonEmptyMapper
创建只输出非Null且非Empty(如List.isEmpty)的属性到Json字符串的Mapper. 注意,要小心使用, 特别留意empty的情况.
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:71
Method
nonNullMapper
创建只输出非Null的属性到Json字符串的Mapper.
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:62
Method
objectSerializer
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/TccConfig.java:53
Method
objectSerializer
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/TccConfig.java:54
Method
objectSerializer
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/TccConfig.java:54
Method
onApplicationEvent
(ContextRefreshedEvent contextRefreshedEvent)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringPostProcessor.java:15
Method
page
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/RechargeController.java:41
Method
process
(String msg)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/receiver/UserPointReceiver.java:30
Method
process
(WatchedEvent watchedEvent)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:157
Method
putAll
(Map<? extends K, ? extends V> m)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:91
Method
reSend
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:107
Method
reSendAllDeadByQueueName
(String queueName, int batchSize)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:158
Method
reSendAllDeadMessageByQueueName
( @PathVariable("queueName") String queueName, @RequestParam("batchSize") int batchSiz
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:87
Method
reSendAllDeadMessageByQueueName
重发某个消息队列中的全部已死亡的消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:79
Method
reSendByMessageId
(String messageId)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:121
Method
reSendMessage
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:53
Method
reSendMessage
重发消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:49
Method
reSendMessageByMessageId
(@PathVariable("messageId") String messageId)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:60
Method
reSendMessageByMessageId
根据messageId重发某条消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:55
Method
recharge
(@RequestBody TransactionEntity<CapitalOrder> entity)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/controller/CapitalController.java:42
Method
recharge
(TransactionContext context, CapitalOrder order)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/CapitalAccountServiceImpl.java:89
Method
recharge
(CapitalOrder order)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/RechargeServiceImpl.java:33
Method
recharge
充值
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/client/proxy/CapitalServiceClientProxy.java:40
Method
recharge
(String username, BigDecimal amount)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/RechargeController.java:46
Method
recharge
用户充值 @param entity 事务实体 @return {@code Result<CapitalOrder>}
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/api/CapitalApi.java:42
Method
register
(@RequestBody User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/UserController.java:25
Method
register
注册用户 @param user 用户 @return User
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserService.java:20
Method
register
(User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:44
Method
register
提交注册 @param user 用户 @return
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/controller/UserController.java:43
Method
register
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/controller/UserController.java:25
Method
register
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserServiceImpl.java:42
Method
registerPage
注册页面 @return
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/controller/UserController.java:32
Method
registerPage
注册页面 @return
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/UserPageController.java:21
Method
releaseConnection
(Connection con)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/repository/SpringJdbcTransactionRepository.java:20
Method
resolveArgument
( MethodParameter parameter, ModelAndViewContainer mavContainer, NativeWebRequest webR
ms-core/src/main/java/com/hason/dtp/core/support/HandlerMethodMultiArgumentResolver.java:35
Method
resolveArgument
Resolve the argument from the model or if not found instantiate it with its default if it is available. The model attribute is then populated with req
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:84
Method
rollback
回滚参与者事务(在Transaction中被调用)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Participant.java:35
Method
rollback
回滚事务.
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:113
Method
save
(@RequestBody User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/UserController.java:31
Method
save
保存用户 @param user 用户 @return User
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserService.java:28
Method
save
保存用户 @param user 用户 @return {@code Result<User>}
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/api/UserApi.java:36
Method
save
(@RequestBody User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/controller/UserController.java:30
Method
saveAndSend
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:79
Method
saveAndSendMessage
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:40
Method
saveMessageWaitingConfirm
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:27
Method
saveMessageWaitingConfirm
预存储消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:22
Method
saveWaitingConfirm
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:44
Method
sendingTimeout
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/timer/MessageStatusTimer.java:26
Method
serialize
(T object)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/JdkSerializationSerializer.java:10
Method
serialize
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/KryoTransactionSerializer.java:38
Method
setAmount
(BigDecimal amount)
tcc-transaction/tcc-order-api/src/main/java/com/hason/dtp/tcc/order/entity/Order.java:62
Method
setApplicationContext
(ApplicationContext applicationContext)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringBeanFactory.java:20
Method
setAttachments
(Map<String, String> attachments)
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionContext.java:47
Method
setBody
(T body)
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:48
Method
setCode
(int code)
ms-core/src/main/java/com/hason/dtp/core/exception/ErrorResult.java:29
Method
setCompensableTransactionInterceptor
设置可补偿事务拦截器. @param compensableTransactionInterceptor
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccCompensableAspect.java:66
Method
setContext
(TransactionContext context)
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:40
Method
setCreator
(String creator)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:132
Method
setDriverClassName
(String driverClassName)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:49
Method
setDriverClassName
(String driverClassName)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:49
Method
setDriverClassName
(String driverClassName)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:49
Method
setDuration
(Map<Integer, Integer> duration)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:47
Method
setDuration
(Map<Integer, Integer> duration)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/config/properties/QueueMessageProperties.java:47
Method
setExpire
(Integer expire)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:64
Method
setExpire
(Integer expire)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/config/properties/QueueMessageProperties.java:64
Method
setExpireDuration
(int durationInSeconds)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:137
Method
setField2
(String field2)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:172
← previous
next →
501–600 of 684, ranked by callers