yoho_mq
2016-04-15 11:44:16 0 举报yoho
作者其他创作
大纲/内容
ConcreteDelayConsumer
DefaultConsumerFactory
ConnectionFactory connectionFactory;RabbitAdmin admin;SimpleMessageConverter simpleMessageConverter ;String context;TopicExchange topicExchange;
addMessageListener(consumers)declareAndGetQueueName(consumer)
ConcreteConsumer
YhMessageConsumer
String getMessageTopic();void handleMessage(Object message);
DelayConsumerFactory
ConnectionFactory connectionFactory;RabbitAdmin admin;SimpleMessageConverter simpleMessageConverter ;String context;TopicExchange topicExchange;TopicExchange expireExchange;
addMessageListener(consumers)declareExpiredQueue(consumer)declareTimeQueue(consumer)
YhDelayMessageConsumer
int getDelayInMinutes();String getMessageTopic();void handleMessage(Object message);
YhProducerTemplate
AmqpTemplate amqpTemplate
0 条评论
下一页
