MCPcopy Create free account

hub / github.com/MFrank2016/delayed-queue-demo / functions

Functions32 in github.com/MFrank2016/delayed-queue-demo

↓ 1 callersMethodgetCode
()
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:15
↓ 1 callersMethodgetDelayTypeEnumByValue
(Integer code)
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:23
↓ 1 callersMethodsendDelayMsg
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/mq/DelayMessageSender.java:36
↓ 1 callersMethodsendMsg
(String msg, Integer delayType)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:22
MethodDelayTypeEnum
(Integer code, String desc)
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:10
MethodbindingNotify
(@Qualifier("immediateQueue") Queue queue, @Qualifier("customExchange") Custo
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:32
MethodcontextLoads
()
src/test/java/com/mfrank/delayqueuedemo/DelayQueueDemoApplicationTests.java:12
MethodcustomExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:25
MethoddeadLetterBindingA
(@Qualifier("deadLetterQueueA") Queue queue, @Qualifier("deadLetterExchang
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:122
MethoddeadLetterBindingB
(@Qualifier("deadLetterQueueB") Queue queue, @Qualifier("deadLetterExcha
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:129
MethoddeadLetterBindingC
(@Qualifier("deadLetterQueueC") Queue queue, @Qualifier("deadLetterExcha
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:136
MethoddeadLetterExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:36
MethoddeadLetterQueueA
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:83
MethoddeadLetterQueueB
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:89
MethoddeadLetterQueueC
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:95
MethoddelayBindingA
(@Qualifier("delayQueueA") Queue queue, @Qualifier("delayExchange") Direct
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:101
MethoddelayBindingB
(@Qualifier("delayQueueB") Queue queue, @Qualifier("delayExchange") Direct
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:108
MethoddelayBindingC
(@Qualifier("delayQueueC") Queue queue, @Qualifier("delayExchange") DirectExc
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:115
MethoddelayExchange
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:30
MethoddelayMsg
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:28
MethoddelayMsg2
(String msg, Integer delayTime)
src/main/java/com/mfrank/delayqueuedemo/controller/RabbitMQMsgController.java:34
MethoddelayQueueA
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:43
MethoddelayQueueB
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:57
MethoddelayQueueC
()
src/main/java/com/mfrank/delayqueuedemo/config/RabbitMQConfig.java:72
MethodgetDesc
()
src/main/java/com/mfrank/delayqueuedemo/constants/DelayTypeEnum.java:19
MethodimmediateQueue
()
src/main/java/com/mfrank/delayqueuedemo/config/DelayedRabbitMQConfig.java:20
Methodmain
(String[] args)
src/main/java/com/mfrank/delayqueuedemo/DelayQueueDemoApplication.java:9
MethodreceiveA
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:20
MethodreceiveB
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:27
MethodreceiveC
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:34
MethodreceiveD
(Message message, Channel channel)
src/main/java/com/mfrank/delayqueuedemo/mq/DeadLetterQueueConsumer.java:41
MethodsendMsg
(String msg, DelayTypeEnum type)
src/main/java/com/mfrank/delayqueuedemo/mq/DelayMessageSender.java:18