MCPcopy Create free account

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

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

MethodhashCode
()
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:99
MethodhashCode
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:75
Methodhello
()
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/HelloController.java:18
Methodincr
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
Methodincr
(@PathVariable("userId") Long userId, @RequestBody TransactionEntity<Long> entity)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/controller/PointController.java:37
Methodincr
(TransactionContext context, Long userId, Long increment)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/service/PointServiceImpl.java:65
Methodinit
()
reliable-message-transaction/rm-account/src/test/java/com/hason/dtp/test/account/dao/UserRepositoryTest.java:30
Methodinit
初始化方法,Spring启动时执行.
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/recover/RecoverScheduledJob.java:35
MethodinterceptCompensableMethod
拦截补偿方法. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/CompensableTransactionInterceptor.java:44
MethodinterceptCompensableMethod
定义环绕通知(在一个方法执行之前和执行之后运行,第一个参数必须是 ProceedingJoinPoint类型,pjp将包含切点拦截的方法的参数信息) @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccCompensableAspect.java:47
MethodinterceptTransactionContextMethod
拦截事务上下文方法. @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:45
MethodinterceptTransactionContextMethod
定义环绕通知(在一个方法执行之前和执行之后运行,第一个参数必须是 ProceedingJoinPoint类型,方法的调用者得到的返回值就是环绕通知返回的值) @param pjp @throws Throwable
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccTransactionContextAspect.java:47
MethodisEmpty
()
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:566
MethodisFactoryOf
(Class clazz)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringBeanFactory.java:27
Methodlevel
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/FeignConfig.java:17
Methodlevel
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/FeignConfig.java:18
Methodmain
(String[] args)
reliable-message-transaction/rm-account-point/src/main/java/com/hason/dtp/account/point/RmAccountPointApplication.java:22
Methodmain
(String[] args)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/RmMessageApplication.java:22
Methodmain
(String[] args)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/RmAccountApplication.java:20
Methodmain
(String[] args)
reliable-message-transaction/rm-account-web/src/test/java/com/hason/dtp/test/account/web/MockConcurrent.java:29
Methodmain
(String[] args)
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/RmAccountWebApplication.java:20
Methodmain
(String[] args)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/RmMessageConsumerApplication.java:20
Methodmain
(String[] args)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/TccCapitalApplication.java:20
Methodmain
(String[] args)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/TccAccountApplication.java:20
Methodmain
测试用: @param args
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:146
Methodmain
(String[] args)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/TccIntegralApplication.java:18
Methodmain
(String[] args)
ms-discovery-eureka/src/main/java/com/hason/dtp/discovery/DiscoveryApplication.java:18
MethodmethodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-account-point/src/main/java/com/hason/dtp/account/point/config/UtilConfig.java:19
MethodmethodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/UtilConfig.java:20
MethodmethodInvokingFactoryBean
(MessageSource source)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/config/UtilConfig.java:19
MethodmethodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/UtilConfig.java:18
MethodmethodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/UtilConfig.java:18
MethodmethodInvokingFactoryBean
(MessageSource source)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/UtilConfig.java:18
MethodnonEmptyMapper
创建只输出非Null且非Empty(如List.isEmpty)的属性到Json字符串的Mapper. 注意,要小心使用, 特别留意empty的情况.
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:71
MethodnonNullMapper
创建只输出非Null的属性到Json字符串的Mapper.
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:62
MethodobjectSerializer
()
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/TccConfig.java:53
MethodobjectSerializer
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/TccConfig.java:54
MethodobjectSerializer
()
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/TccConfig.java:54
MethodonApplicationEvent
(ContextRefreshedEvent contextRefreshedEvent)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringPostProcessor.java:15
Methodpage
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/RechargeController.java:41
Methodprocess
(String msg)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/receiver/UserPointReceiver.java:30
Methodprocess
(WatchedEvent watchedEvent)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:157
MethodputAll
(Map<? extends K, ? extends V> m)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:91
MethodreSend
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:107
MethodreSendAllDeadByQueueName
(String queueName, int batchSize)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:158
MethodreSendAllDeadMessageByQueueName
( @PathVariable("queueName") String queueName, @RequestParam("batchSize") int batchSiz
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:87
MethodreSendAllDeadMessageByQueueName
重发某个消息队列中的全部已死亡的消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:79
MethodreSendByMessageId
(String messageId)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:121
MethodreSendMessage
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:53
MethodreSendMessage
重发消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:49
MethodreSendMessageByMessageId
(@PathVariable("messageId") String messageId)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:60
MethodreSendMessageByMessageId
根据messageId重发某条消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:55
Methodrecharge
(@RequestBody TransactionEntity<CapitalOrder> entity)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/controller/CapitalController.java:42
Methodrecharge
(TransactionContext context, CapitalOrder order)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/CapitalAccountServiceImpl.java:89
Methodrecharge
(CapitalOrder order)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/RechargeServiceImpl.java:33
Methodrecharge
充值
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/client/proxy/CapitalServiceClientProxy.java:40
Methodrecharge
(String username, BigDecimal amount)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/RechargeController.java:46
Methodrecharge
用户充值 @param entity 事务实体 @return {@code Result<CapitalOrder>}
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/api/CapitalApi.java:42
Methodregister
(@RequestBody User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/UserController.java:25
Methodregister
注册用户 @param user 用户 @return User
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserService.java:20
Methodregister
(User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserServiceImpl.java:44
Methodregister
提交注册 @param user 用户 @return
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/controller/UserController.java:43
Methodregister
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/controller/UserController.java:25
Methodregister
(User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserServiceImpl.java:42
MethodregisterPage
注册页面 @return
reliable-message-transaction/rm-account-web/src/main/java/com/hason/dtp/account/web/controller/UserController.java:32
MethodregisterPage
注册页面 @return
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/web/UserPageController.java:21
MethodreleaseConnection
(Connection con)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/repository/SpringJdbcTransactionRepository.java:20
MethodresolveArgument
( MethodParameter parameter, ModelAndViewContainer mavContainer, NativeWebRequest webR
ms-core/src/main/java/com/hason/dtp/core/support/HandlerMethodMultiArgumentResolver.java:35
MethodresolveArgument
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
Methodrollback
回滚参与者事务(在Transaction中被调用)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Participant.java:35
Methodrollback
回滚事务.
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:113
Methodsave
(@RequestBody User user)
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/controller/UserController.java:31
Methodsave
保存用户 @param user 用户 @return User
reliable-message-transaction/rm-account/src/main/java/com/hason/dtp/account/service/UserService.java:28
Methodsave
保存用户 @param user 用户 @return {@code Result<User>}
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/api/UserApi.java:36
Methodsave
(@RequestBody User user)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/controller/UserController.java:30
MethodsaveAndSend
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:79
MethodsaveAndSendMessage
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:40
MethodsaveMessageWaitingConfirm
(@RequestBody Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/controller/MessageController.java:27
MethodsaveMessageWaitingConfirm
预存储消息.
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/api/MessageApi.java:22
MethodsaveWaitingConfirm
(Message message)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:44
MethodsendingTimeout
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/timer/MessageStatusTimer.java:26
Methodserialize
(T object)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/JdkSerializationSerializer.java:10
Methodserialize
(Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/KryoTransactionSerializer.java:38
MethodsetAmount
(BigDecimal amount)
tcc-transaction/tcc-order-api/src/main/java/com/hason/dtp/tcc/order/entity/Order.java:62
MethodsetApplicationContext
(ApplicationContext applicationContext)
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/support/SpringBeanFactory.java:20
MethodsetAttachments
(Map<String, String> attachments)
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionContext.java:47
MethodsetBody
(T body)
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:48
MethodsetCode
(int code)
ms-core/src/main/java/com/hason/dtp/core/exception/ErrorResult.java:29
MethodsetCompensableTransactionInterceptor
设置可补偿事务拦截器. @param compensableTransactionInterceptor
tcc-transaction/tcc-framework/tcc-transaction-spring/src/main/java/org/mengyun/tcctransaction/spring/TccCompensableAspect.java:66
MethodsetContext
(TransactionContext context)
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:40
MethodsetCreator
(String creator)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:132
MethodsetDriverClassName
(String driverClassName)
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/config/properties/TccDataSourceProperties.java:49
MethodsetDriverClassName
(String driverClassName)
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:49
MethodsetDriverClassName
(String driverClassName)
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/config/properties/TccDataSourceProperties.java:49
MethodsetDuration
(Map<Integer, Integer> duration)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:47
MethodsetDuration
(Map<Integer, Integer> duration)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/config/properties/QueueMessageProperties.java:47
MethodsetExpire
(Integer expire)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:64
MethodsetExpire
(Integer expire)
reliable-message-transaction/rm-message-consumer/src/main/java/com/hason/dtp/message/consumer/config/properties/QueueMessageProperties.java:64
MethodsetExpireDuration
(int durationInSeconds)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:137
MethodsetField2
(String field2)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:172
← previousnext →501–600 of 684, ranked by callers