yoho_mq_simple
2016-04-15 11:44:16 0 举报yoho
作者其他创作
大纲/内容
ConcreteConsumer
topic:myTopic
YhMessageConsumer
String getMessageTopic();void handleMessage(Object message);
消费者回调
监听
队列
YhProducerTemplate
AmqpTemplate amqpTemplate
DefaultConsumerFactory
ConnectionFactory connectionFactory;RabbitAdmin admin;SimpleMessageConverter simpleMessageConverter ;String context;TopicExchange topicExchange;
addMessageListener(consumers)declareAndGetQueueName(consumer)
提供topic：1创建队列，2绑定队列
SimpleMessageListenerContainer
topic：myTopic
发送消息
amq.topic
Exchange
create
yoho:模块名:myTopic
0 条评论
下一页
