接口的使用
wang.bigbird.domain.framework.data.rabbitmq.handler.RabbitmqConsumerHandler

使用RabbitmqConsumerHandler的程序包

程序包	说明
wang.bigbird.domain.framework.data.rabbitmq.handler
wang.bigbird.domain.framework.data.rabbitmq.service
wang.bigbird.domain.framework.data.rabbitmq.service.impl

wang.bigbird.domain.framework.data.rabbitmq.handler中RabbitmqConsumerHandler的使用

类型参数类型为RabbitmqConsumerHandler的wang.bigbird.domain.framework.data.rabbitmq.handler中的字段

限定符和类型	字段和说明
static Map<String,RabbitmqConsumerHandler>	MessageHandler.queueMessageConsumerHandlerMap 队列消息数据对应的处理器

参数类型为RabbitmqConsumerHandler的wang.bigbird.domain.framework.data.rabbitmq.handler中的方法

限定符和类型	方法和说明
static <T> void	MessageHandler.parseMessage(org.springframework.amqp.core.Message message, Class<T> messageClass, RabbitmqConsumerHandler<T> handler) 拆解消息进行处理

wang.bigbird.domain.framework.data.rabbitmq.service中RabbitmqConsumerHandler的使用

参数类型为RabbitmqConsumerHandler的wang.bigbird.domain.framework.data.rabbitmq.service中的方法

限定符和类型	方法和说明
<T> void	RabbitmqConsumerService.consume(String queueName, Class<T> messageClass, RabbitmqConsumerHandler<T> handler) 消费指定队列的消息，采用rabbitTemplate.receiveAndConvert()方式循环主动拉取消息实现 由于拉取消息会导致消息从队列中删除，因此采用该方法对于fanout和topic两种类型的队列无法保 证每个消费端都能获得消息，如果要实现fanout和topic对应的消息被所有消费者处理，请采用@RabbitListener 实现消息消费
<T> void	RabbitmqConsumerService.listen(String queueName, Class<T> messageClass, RabbitmqConsumerHandler<T> handler) 消费指定队列的消息，采用监听模式，效果等同于@RabbitListener

wang.bigbird.domain.framework.data.rabbitmq.service.impl中RabbitmqConsumerHandler的使用

参数类型为RabbitmqConsumerHandler的wang.bigbird.domain.framework.data.rabbitmq.service.impl中的方法

限定符和类型	方法和说明
<T> void	RabbitmqConsumerServiceImpl.consume(String queueName, Class<T> messageClass, RabbitmqConsumerHandler<T> handler)
<T> void	RabbitmqConsumerServiceImpl.listen(String queueName, Class<T> messageClass, RabbitmqConsumerHandler<T> handler)