yoho_mq_delay
2016-04-15 11:44:16 0 举报yoho
作者其他创作
大纲/内容
Exchange
ConcreteDelayConsumer
delay:10topic:mytopic
create
消费者回调
yoho.expire
监听
YhDelayMessageConsumer
int getDelayInMinutes();String getMessageTopic();void handleMessage(Object message);
YhProducerTemplate
AmqpTemplate amqpTemplate
SimpleMessageListenerContainer
topic:yoho_delay.10m.*
topic:yoho_delay.*.mytopic
普通队列
DelayConsumerFactory
ConnectionFactory connectionFactory;RabbitAdmin admin;SimpleMessageConverter simpleMessageConverter ;String context;TopicExchange topicExchange;TopicExchange expireExchange;
addMessageListener(consumers)declareExpiredQueue(consumer)declareTimeQueue(consumer)
发送延时消息(topic:yoho_delay.[delayInMinutes]m.topic)
amq.topic
yoho:模块名:mytopic
超时队列
x-dead-letter-exchange
delay:10m.queue
0 条评论
下一页
为你推荐
查看更多
