Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MFrank2016/delayed-queue-demo
/ functions
Functions
32 in github.com/MFrank2016/delayed-queue-demo
⨍
Functions
32
◇
Types & classes
8
↓ 1 callers
Method
getCode
()
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:15
↓ 1 callers
Method
getDelayTypeEnumByValue
(Integer code)
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:23
↓ 1 callers
Method
sendDelayMsg
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/mq/DelayMessageSender.java:36
↓ 1 callers
Method
sendMsg
(String msg, Integer delayType)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:22
Method
DelayTypeEnum
(Integer code, String desc)
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:10
Method
bindingNotify
(@Qualifier("immediateQueue") Queue queue, @Qualifier("customExchange") Custo
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:32
Method
contextLoads
()
src/test/java/com/mfrank/delayqueuedemo/DelayQueueDemoApplicationTests.java:12
Method
customExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:25
Method
deadLetterBindingA
(@Qualifier("deadLetterQueueA") Queue queue, @Qualifier("deadLetterExchang
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:122
Method
deadLetterBindingB
(@Qualifier("deadLetterQueueB") Queue queue, @Qualifier("deadLetterExcha
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:129
Method
deadLetterBindingC
(@Qualifier("deadLetterQueueC") Queue queue, @Qualifier("deadLetterExcha
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:136
Method
deadLetterExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:36
Method
deadLetterQueueA
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:83
Method
deadLetterQueueB
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:89
Method
deadLetterQueueC
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:95
Method
delayBindingA
(@Qualifier("delayQueueA") Queue queue, @Qualifier("delayExchange") Direct
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:101
Method
delayBindingB
(@Qualifier("delayQueueB") Queue queue, @Qualifier("delayExchange") Direct
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:108
Method
delayBindingC
(@Qualifier("delayQueueC") Queue queue, @Qualifier("delayExchange") DirectExc
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:115
Method
delayExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:30
Method
delayMsg
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:28
Method
delayMsg2
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:34
Method
delayQueueA
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:43
Method
delayQueueB
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:57
Method
delayQueueC
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:72
Method
getDesc
()
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:19
Method
immediateQueue
()
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:20
Method
main
(String[] args)
src/main/java/com/mfrank/delayqueuedemo/DelayQueueDemoApplication.java:9
Method
receiveA
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:20
Method
receiveB
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:27
Method
receiveC
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:34
Method
receiveD
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:41
Method
sendMsg
(String msg, DelayTypeEnum type)
src/main/java/com/mfrank/delayqueuedemo/mq/DelayMessageSender.java:18