wang.bigbird.domain.framework.data.rabbitmq.service.impl

类 RabbitmqConsumerServiceImpl

java.lang.Object

wang.bigbird.domain.framework.data.rabbitmq.service.impl.RabbitmqConsumerServiceImpl

所有已实现的接口:

RabbitmqConsumerService

@Service
public class RabbitmqConsumerServiceImpl
extends Object
implements RabbitmqConsumerService

rabbitmq消费者服务

作者:

Bigbird

构造器概要

构造器

构造器和说明
RabbitmqConsumerServiceImpl()

方法概要

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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RabbitmqConsumerServiceImpl

public RabbitmqConsumerServiceImpl()

方法详细资料

consume

public <T> void consume(String queueName,
                        Class<T> messageClass,
                        RabbitmqConsumerHandler<T> handler)

从接口复制的说明: RabbitmqConsumerService

消费指定队列的消息，采用rabbitTemplate.receiveAndConvert()方式循环主动拉取消息实现 由于拉取消息会导致消息从队列中删除，因此采用该方法对于fanout和topic两种类型的队列无法保 证每个消费端都能获得消息，如果要实现fanout和topic对应的消息被所有消费者处理，请采用@RabbitListener 实现消息消费

指定者:

consume 在接口中 RabbitmqConsumerService

参数:

queueName - 队列名

messageClass - 消息类型

handler - 函数式处理

listen

public <T> void listen(String queueName,
                       Class<T> messageClass,
                       RabbitmqConsumerHandler<T> handler)

从接口复制的说明: RabbitmqConsumerService

消费指定队列的消息，采用监听模式，效果等同于@RabbitListener

指定者:

listen 在接口中 RabbitmqConsumerService

参数:

queueName - 队列名

messageClass - 消息类型

handler - 函数式处理