ActiveMQ:如何从非持久订阅中 subscribe/unsubscribe
ActiveMQ: how to subscribe/unsubscribe from non-durable subscriptions
我必须为我正在上的大学课程做一个项目,但因为找不到对一个简单问题的澄清而陷入困境:
作为非长期订阅者,如何正确订阅和取消订阅主题?听起来很简单,但是对于持久化有一个取消订阅的方法,我只是不知道非持久化使用什么。
我想做的是能够随意订阅、取消订阅和重新订阅任何主题。我发现 post 说你应该使用 consumer.close();取消订阅,但我不知道如何重新订阅。 consumer.start();未被识别为命令(消费者是 class MessageConsumer 的一个实例)。
所以
取消订阅 = consumer.close(); //对吗?
取消订阅后重新订阅 = 消费者。???
还是每次重新订阅都需要创建一个新的消费者?
编程语言:Java
对于非持久主题订阅,没有重新订阅这样的事情。您要么 activity 订阅了,要么没有订阅。订阅您创建一个消费者,当消费者处于活动状态时,他们将接收发送到主题的消息,以删除您关闭消费者的订阅。如果您随后决定要订阅和收听主题消息,您将创建一个新的消费者,这是一个全新的订阅,它将再次仅接收在该订阅者处于活动状态时发送的消息。
对于非持久订阅,你只需要做一个:
consumer.close()
就是这么说的 here :
我必须为我正在上的大学课程做一个项目,但因为找不到对一个简单问题的澄清而陷入困境:
作为非长期订阅者,如何正确订阅和取消订阅主题?听起来很简单,但是对于持久化有一个取消订阅的方法,我只是不知道非持久化使用什么。
我想做的是能够随意订阅、取消订阅和重新订阅任何主题。我发现 post 说你应该使用 consumer.close();取消订阅,但我不知道如何重新订阅。 consumer.start();未被识别为命令(消费者是 class MessageConsumer 的一个实例)。
所以 取消订阅 = consumer.close(); //对吗?
取消订阅后重新订阅 = 消费者。??? 还是每次重新订阅都需要创建一个新的消费者?
编程语言:Java
对于非持久主题订阅,没有重新订阅这样的事情。您要么 activity 订阅了,要么没有订阅。订阅您创建一个消费者,当消费者处于活动状态时,他们将接收发送到主题的消息,以删除您关闭消费者的订阅。如果您随后决定要订阅和收听主题消息,您将创建一个新的消费者,这是一个全新的订阅,它将再次仅接收在该订阅者处于活动状态时发送的消息。
对于非持久订阅,你只需要做一个:
consumer.close()
就是这么说的 here :