Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/chanjarster/artemis-disruptor-miaosha
/ functions
Functions
306 in github.com/chanjarster/artemis-disruptor-miaosha
⨍
Functions
306
◇
Types & classes
86
↓ 22 callers
Method
toString
()
jms-base/src/main/java/me/chanjar/jms/base/sender/simple/SimpleJmsMessageSender.java:51
↓ 10 callers
Method
getId
()
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:28
↓ 5 callers
Method
registerSingleton
(ApplicationContext applicationContext, String beanName, Object singletonObject)
jms-base/src/main/java/me/chanjar/jms/base/utils/BeanRegisterUtils.java:13
↓ 4 callers
Method
clear
清空缓存
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:24
↓ 4 callers
Method
get
获得{@link Command} @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:31
↓ 4 callers
Method
getMessageSelector
()
jms-base/src/main/java/me/chanjar/jms/base/factory/consumer/MessageConsumerOption.java:10
↓ 4 callers
Method
getRequestDto
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:21
↓ 4 callers
Method
setSuccess
(boolean success)
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:47
↓ 3 callers
Method
get
(Long id)
jms-server/src/main/java/me/chanjar/jms/server/memdb/ItemRepository.java:10
↓ 3 callers
Method
getCommand
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEvent.java:9
↓ 3 callers
Method
getCommandCollector
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:33
↓ 3 callers
Method
getItemId
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommand.java:27
↓ 3 callers
Method
put
放入Command @param command
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:19
↓ 3 callers
Method
requestSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:52
↓ 3 callers
Method
responseSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:84
↓ 3 callers
Method
setErrorMessage
(String errorMessage)
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:39
↓ 2 callers
Method
addCommand
(Command command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandCollector.java:18
↓ 2 callers
Method
create
得到返回的结果后, 必须执行 {@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 callers
Method
createMessageConsumer
@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 callers
Method
createMessageProducer
( Session session, Destination destination, MessageProducerOption producerOption)
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerFactory.java:13
↓ 2 callers
Method
createSession
(Connection connection, SessionOption sessionOption)
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionFactory.java:13
↓ 2 callers
Method
createSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:136
↓ 2 callers
Method
createSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:130
↓ 2 callers
Method
defaultConnectionFactory
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:25
↓ 2 callers
Method
flushBuffer
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEventDbHandler.java:34
↓ 2 callers
Method
fromMessage
把{@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 callers
Method
getCommandList
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandCollector.java:14
↓ 2 callers
Method
getDisruptor
()
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/DisruptorJmsMessageSender.java:83
↓ 2 callers
Method
getItemId
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommand.java:26
↓ 2 callers
Method
getMatchClass
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandProcessor.java:8
↓ 2 callers
Method
getNextId
()
jms-base/src/main/java/me/chanjar/jms/base/utils/StrongUuidGenerator.java:15
↓ 2 callers
Method
getNoLocal
()
jms-base/src/main/java/me/chanjar/jms/base/factory/consumer/MessageConsumerOption.java:23
↓ 2 callers
Method
getNum
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:110
↓ 2 callers
Method
getNum
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:104
↓ 2 callers
Method
getPayload
()
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEvent.java:7
↓ 2 callers
Method
getRequestId
()
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:31
↓ 2 callers
Method
hasErrorOrException
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:47
↓ 2 callers
Method
onData
(T command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEventProducer.java:18
↓ 2 callers
Method
put
放入响应结果 @param responseDto
jms-client/src/main/java/me/chanjar/jms/client/command/ResponseCache.java:15
↓ 2 callers
Method
put
(Item item)
jms-server/src/main/java/me/chanjar/jms/server/memdb/ItemRepository.java:8
↓ 2 callers
Method
registerCommandProcessor
(CommandProcessor commandProcessor)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandDispatcher.java:10
↓ 2 callers
Method
requestMessageProducer
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:64
↓ 2 callers
Method
requestSession
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:50
↓ 2 callers
Method
responseMessageProducer
()
jms-server/src/main/java/me/chanjar/jms/server/config/JmsServerConfiguration.java:94
↓ 2 callers
Method
responseSession
()
jms-client/src/main/java/me/chanjar/jms/client/config/JmsClientConfiguration.java:98
↓ 2 callers
Method
sendMessage
发送Jms消息 @param payload 消息主体 @throws JMSException
jms-base/src/main/java/me/chanjar/jms/base/sender/JmsMessageSender.java:18
↓ 2 callers
Method
setAcknowledgeMode
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 callers
Method
setId
(Message message, Object payload)
jms-base/src/main/java/me/chanjar/jms/base/utils/DupMessageDetectStrategy.java:12
↓ 2 callers
Method
setPayload
(Object payload)
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEvent.java:11
↓ 2 callers
Method
setResponseDto
(ResponseDto responseDto)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:29
↓ 2 callers
Method
setTransacted
Default - false. @param transacted @see Session#getTransacted()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:35
↓ 2 callers
Method
toMessage
把对象转换成{@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 callers
Method
clearForGc
()
jms-server/src/main/java/me/chanjar/jms/server/command/infras/disruptor/CommandEvent.java:17
↓ 1 callers
Method
clearForGc
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:41
↓ 1 callers
Method
commandDispatcher
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:33
↓ 1 callers
Method
createExceptionResponseDto
(String requestId, String exception)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEventExceptionHandler.java:23
↓ 1 callers
Method
decreaseAmount
减库存,如果库存不足,则扣减失败 @return
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:45
↓ 1 callers
Method
defaultConnection
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:36
↓ 1 callers
Method
dispatch
(Command command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandDispatcher.java:8
↓ 1 callers
Method
doLoad
()
jms-server/src/main/java/me/chanjar/jms/server/dataloader/DataStartupLoader.java:46
↓ 1 callers
Method
doRequest
(RequestDto requestDto)
jms-client/src/main/java/me/chanjar/jms/client/command/MiaoShaCommandService.java:8
↓ 1 callers
Method
execute
(T commandBuffer)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandExecutor.java:8
↓ 1 callers
Method
getAcknowledgeMode
()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:11
↓ 1 callers
Method
getAmount
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommand.java:31
↓ 1 callers
Method
getAmount
()
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:32
↓ 1 callers
Method
getAndRemove
获得响应结果,并将其从缓存中删除 @param requestId @return
jms-client/src/main/java/me/chanjar/jms/client/command/ResponseCache.java:23
↓ 1 callers
Method
getDeliveryDelay
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:91
↓ 1 callers
Method
getDeliveryMode
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:75
↓ 1 callers
Method
getErrorMessage
()
jms-msg/src/main/java/me/chanjar/jms/msg/ResponseDto.java:35
↓ 1 callers
Method
getId
()
jms-base/src/main/java/me/chanjar/jms/base/msg/MessageDto.java:19
↓ 1 callers
Method
getId
全局唯一Id, uuid @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/Command.java:33
↓ 1 callers
Method
getItemId
()
jms-msg/src/main/java/me/chanjar/jms/msg/RequestDto.java:28
↓ 1 callers
Method
getJvmQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:89
↓ 1 callers
Method
getPassword
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:86
↓ 1 callers
Method
getPriority
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:79
↓ 1 callers
Method
getQueue
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:94
↓ 1 callers
Method
getQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:126
↓ 1 callers
Method
getQueueSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:120
↓ 1 callers
Method
getResponse
(String requestId)
jms-client/src/main/java/me/chanjar/jms/client/command/MiaoShaCommandService.java:10
↓ 1 callers
Method
getResponseDto
()
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java:37
↓ 1 callers
Method
getSqlBufferSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/OrderInsertProcessorConfiguration.java:118
↓ 1 callers
Method
getSqlBufferSize
()
jms-server/src/main/java/me/chanjar/jms/server/config/ItemAmountUpdateProcessorConfiguration.java:112
↓ 1 callers
Method
getTimeToLive
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:71
↓ 1 callers
Method
getTopic
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:102
↓ 1 callers
Method
getUri
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:70
↓ 1 callers
Method
getUser
假的,获得当前用户名的方法 @return
web/src/main/java/me/chanjar/MiaoshaRestController.java:59
↓ 1 callers
Method
getUserId
()
jms-msg/src/main/java/me/chanjar/jms/msg/RequestDto.java:32
↓ 1 callers
Method
getUserId
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommand.java:30
↓ 1 callers
Method
getUsername
()
jms-base/src/main/java/me/chanjar/jms/base/config/ArtemisJmsConfiguration.java:78
↓ 1 callers
Method
hasRemaining
Buffer是否已经满了 @return
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandBuffer.java:12
↓ 1 callers
Method
hasRemaining
()
jms-server/src/main/java/me/chanjar/jms/server/command/item/ItemAmountUpdateCommandBuffer.java:32
↓ 1 callers
Method
hasRemaining
()
jms-server/src/main/java/me/chanjar/jms/server/command/order/OrderInsertCommandBuffer.java:25
↓ 1 callers
Method
hasRemaining
是否还有库存 @return
jms-server/src/main/java/me/chanjar/jms/server/memdb/Item.java:60
↓ 1 callers
Method
isDisableMessageId
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:83
↓ 1 callers
Method
isDisableMessageTimestamp
()
jms-base/src/main/java/me/chanjar/jms/base/factory/producer/MessageProducerOption.java:87
↓ 1 callers
Method
isTransacted
()
jms-base/src/main/java/me/chanjar/jms/base/factory/session/SessionOption.java:25
↓ 1 callers
Method
onData
(Object payload)
jms-base/src/main/java/me/chanjar/jms/base/sender/disruptor/PayloadEventProducer.java:19
↓ 1 callers
Method
onData
(RequestDto requestDto)
jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEventProducer.java:18
↓ 1 callers
Method
process
(T command)
jms-server/src/main/java/me/chanjar/jms/server/command/infras/CommandProcessor.java:10
↓ 1 callers
Method
requestDtoEventBusinessHandler
()
jms-server/src/main/java/me/chanjar/jms/server/config/RequestDisruptorConfiguration.java:73
next →
1–100 of 306, ranked by callers