MCPcopy Index your code

hub / github.com/chanjarster/artemis-disruptor-miaosha / functions

Functions306 in github.com/chanjarster/artemis-disruptor-miaosha

↓ 22 callersMethodtoString
()
jms-base/src/main/java/me/chanjar/jms/base/sender/simple/SimpleJmsMessageSender.java:51
↓ 10 callersMethodgetId
()
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:28
↓ 5 callersMethodregisterSingleton
(ApplicationContext applicationContext, String beanName, Object singletonObject)
jms-base/src/main/java/me/chanjar/jms/base/utils/BeanRegisterUtils.java:13
↓ 4 callersMethodclear
清空缓存
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:24
↓ 4 callersMethodget
获得{@link Command} @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:31
↓ 4 callersMethodgetMessageSelector
()
jms-base/src/main/java/me/chanjar/jms/base/factory/consumer/MessageConsumerOption.java:10
↓ 4 callersMethodgetRequestDto
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:21
↓ 4 callersMethodsetSuccess
(boolean success)
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:47
↓ 3 callersMethodget
(Long id)
jms-server/src/main/java/me/chanjar/jms/server/memdb/ItemRepository.java:10
↓ 3 callersMethodgetCommand
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEvent.java:9
↓ 3 callersMethodgetCommandCollector
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:33
↓ 3 callersMethodgetItemId
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommand.java:27
↓ 3 callersMethodput
放入Command @param command
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:19
↓ 3 callersMethodrequestSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:52
↓ 3 callersMethodresponseSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:84
↓ 3 callersMethodsetErrorMessage
(String errorMessage)
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:39
↓ 2 callersMethodaddCommand
(Command command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandCollector.java:18
↓ 2 callersMethodcreate
得到返回的结果后, 必须执行 {@link DisruptorJmsMessageSender#getDisruptor()}.start() 才可以使用 @param session @param messageProducer @param dupMessageDetectStrategy @
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/DisruptorJmsMessageSenderFactory.java:26
↓ 2 callersMethodcreateMessageConsumer
@param session @param destination @param option @param messageListener 可选 @return @throws JMSException
jms-base/src/main/java/me/chanjar/jms/base/factory/consumer/MessageConsumerFactory.java:18
↓ 2 callersMethodcreateMessageProducer
( Session session, Destination destination, MessageProducerOption producerOption)
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerFactory.java:13
↓ 2 callersMethodcreateSession
(Connection connection, SessionOption sessionOption)
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionFactory.java:13
↓ 2 callersMethodcreateSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:136
↓ 2 callersMethodcreateSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:130
↓ 2 callersMethoddefaultConnectionFactory
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:25
↓ 2 callersMethodflushBuffer
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEventDbHandler.java:34
↓ 2 callersMethodfromMessage
把{@link Message}转换成对象 @param jmsTemplate @param message @param <T> @return @throws JMSException
jms-base/src/main/java/me/chanjar/jms/base/utils/MessageConvertUtils.java:53
↓ 2 callersMethodgetCommandList
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandCollector.java:14
↓ 2 callersMethodgetDisruptor
()
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/DisruptorJmsMessageSender.java:83
↓ 2 callersMethodgetItemId
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommand.java:26
↓ 2 callersMethodgetMatchClass
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandProcessor.java:8
↓ 2 callersMethodgetNextId
()
jms-base/src/main/java/me/chanjar/jms/base/utils/StrongUuidGenerator.java:15
↓ 2 callersMethodgetNoLocal
()
jms-base/src/main/java/me/chanjar/jms/base/factory/consumer/MessageConsumerOption.java:23
↓ 2 callersMethodgetNum
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:110
↓ 2 callersMethodgetNum
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:104
↓ 2 callersMethodgetPayload
()
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEvent.java:7
↓ 2 callersMethodgetRequestId
()
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:31
↓ 2 callersMethodhasErrorOrException
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:47
↓ 2 callersMethodonData
(T command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEventProducer.java:18
↓ 2 callersMethodput
放入响应结果 @param responseDto
jms-client/src/main/java/me/chanjar/jms/client/command/ResponseCache.java:15
↓ 2 callersMethodput
(Item item)
jms-server/src/main/java/me/chanjar/jms/server/memdb/ItemRepository.java:8
↓ 2 callersMethodregisterCommandProcessor
(CommandProcessor commandProcessor)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandDispatcher.java:10
↓ 2 callersMethodrequestMessageProducer
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:64
↓ 2 callersMethodrequestSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:50
↓ 2 callersMethodresponseMessageProducer
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:94
↓ 2 callersMethodresponseSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:98
↓ 2 callersMethodsendMessage
发送Jms消息 @param payload 消息主体 @throws JMSException
jms-base/src/main/java/me/chanjar/jms/base/sender/JmsMessageSender.java:18
↓ 2 callersMethodsetAcknowledgeMode
Default - {@link Session#AUTO_ACKNOWLEDGE} @param acknowledgeMode @see Session#getAcknowledgeMode()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:21
↓ 2 callersMethodsetId
(Message message, Object payload)
jms-base/src/main/java/me/chanjar/jms/base/utils/DupMessageDetectStrategy.java:12
↓ 2 callersMethodsetPayload
(Object payload)
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEvent.java:11
↓ 2 callersMethodsetResponseDto
(ResponseDto responseDto)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:29
↓ 2 callersMethodsetTransacted
Default - false. @param transacted @see Session#getTransacted()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:35
↓ 2 callersMethodtoMessage
把对象转换成{@link Message} @param jmsTemplate @param session @param payload @return @throws JMSException
jms-base/src/main/java/me/chanjar/jms/base/utils/MessageConvertUtils.java:26
↓ 1 callersMethodclearForGc
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEvent.java:17
↓ 1 callersMethodclearForGc
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:41
↓ 1 callersMethodcommandDispatcher
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:33
↓ 1 callersMethodcreateExceptionResponseDto
(String requestId, String exception)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEventExceptionHandler.java:23
↓ 1 callersMethoddecreaseAmount
减库存,如果库存不足,则扣减失败 @return
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:45
↓ 1 callersMethoddefaultConnection
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:36
↓ 1 callersMethoddispatch
(Command command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandDispatcher.java:8
↓ 1 callersMethoddoLoad
()
jms-server/src/main/java/me/chanjar/jms/server/dataloader/DataStartupLoader.java:46
↓ 1 callersMethoddoRequest
(RequestDto requestDto)
jms-client/src/main/java/me/chanjar/jms/client/command/MiaoShaCommandService.java:8
↓ 1 callersMethodexecute
(T commandBuffer)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandExecutor.java:8
↓ 1 callersMethodgetAcknowledgeMode
()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:11
↓ 1 callersMethodgetAmount
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommand.java:31
↓ 1 callersMethodgetAmount
()
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:32
↓ 1 callersMethodgetAndRemove
获得响应结果,并将其从缓存中删除 @param requestId @return
jms-client/src/main/java/me/chanjar/jms/client/command/ResponseCache.java:23
↓ 1 callersMethodgetDeliveryDelay
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:91
↓ 1 callersMethodgetDeliveryMode
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:75
↓ 1 callersMethodgetErrorMessage
()
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:35
↓ 1 callersMethodgetId
()
jms-base/src/main/java/me/chanjar/jms/base/msg/MessageDto.java:19
↓ 1 callersMethodgetId
全局唯一Id, uuid @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/Command.java:33
↓ 1 callersMethodgetItemId
()
jms-msg/src/main/java/me/chanjar/jms/msg/RequestDto.java:28
↓ 1 callersMethodgetJvmQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:89
↓ 1 callersMethodgetPassword
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:86
↓ 1 callersMethodgetPriority
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:79
↓ 1 callersMethodgetQueue
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:94
↓ 1 callersMethodgetQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:126
↓ 1 callersMethodgetQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:120
↓ 1 callersMethodgetResponse
(String requestId)
jms-client/src/main/java/me/chanjar/jms/client/command/MiaoShaCommandService.java:10
↓ 1 callersMethodgetResponseDto
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:37
↓ 1 callersMethodgetSqlBufferSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:118
↓ 1 callersMethodgetSqlBufferSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:112
↓ 1 callersMethodgetTimeToLive
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:71
↓ 1 callersMethodgetTopic
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:102
↓ 1 callersMethodgetUri
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:70
↓ 1 callersMethodgetUser
假的,获得当前用户名的方法 @return
web/src/main/java/me/chanjar/MiaoshaRestController.java:59
↓ 1 callersMethodgetUserId
()
jms-msg/src/main/java/me/chanjar/jms/msg/RequestDto.java:32
↓ 1 callersMethodgetUserId
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommand.java:30
↓ 1 callersMethodgetUsername
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:78
↓ 1 callersMethodhasRemaining
Buffer是否已经满了 @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:12
↓ 1 callersMethodhasRemaining
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommandBuffer.java:32
↓ 1 callersMethodhasRemaining
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommandBuffer.java:25
↓ 1 callersMethodhasRemaining
是否还有库存 @return
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:60
↓ 1 callersMethodisDisableMessageId
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:83
↓ 1 callersMethodisDisableMessageTimestamp
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:87
↓ 1 callersMethodisTransacted
()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:25
↓ 1 callersMethodonData
(Object payload)
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEventProducer.java:19
↓ 1 callersMethodonData
(RequestDto requestDto)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEventProducer.java:18
↓ 1 callersMethodprocess
(T command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandProcessor.java:10
↓ 1 callersMethodrequestDtoEventBusinessHandler
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:73
next →1–100 of 306, ranked by callers