Multiple @RqueueListener for a queue about rqueue HOT 5 CLOSED

Yes
It's not supported, why would you do that?

from rqueue.

example: user info change

1: send mail to phone
2: update user info cache ( If an exception occurs, other services can be executed normally )
3: the topic of this subscription other business

I think this is subscription service
Rqueue = async multithreading

@Component
@Slf4j
public class RQueueMessageListener {
    @RqueueListener(value = "user-info-change")
    public void simpleMessage(String message) {
        // update user cahche
        // send mail
        // password change is re login? 
        // ....
    }

    // Multiple business  @RqueueListener 

    @RqueueListener(value = "user-info-change"")
    public void simpleMessage2(String message) {
        //  update user cahche  ( No effect ) 
    }

    @RqueueListener(value = "user-info-change"")
    public void simpleMessage2(String message) {
        // send mail      ( An error occurred )
    }

    @RqueueListener(value = "user-info-change"")
    public void simpleMessage2(String message) {
        // password change is re login? (No effect )
    }
}

from rqueue.

IIUC you're trying to attach more than one listener on a queue and you are expecting same message should be consumed by each consumer that's simply not possible as of now queue does not feature like topic.

You can't do, enqueue message M1 to queue q1 and you have attached multiple listeners l1, l2 , l3, ... to queue q1. In this case only one of your listeners would get the message M1 not every attached listener.

IIUC you're looking for multiplexing that's currently not supported, this feature is also known as consumer group in queuing system like Kafka.

from rqueue.

@victory-wu would you mind giving a try a new wip Rqueue, that can solve your problem?

from rqueue.

Rqueue 2.5.0 supports this feature, see this for usage

https://github.com/sonus21/rqueue/blob/master/rqueue-spring-common-test/src/main/java/com/github/sonus21/rqueue/test/UserBannedMessageListener.java

from rqueue.