我们有一个用例,其中我们的一些侦听器需要具有不同的消息执行器线程数。或者更确切地说,一些队列侦听器需要比其他队列侦听器更少的并发消息处理。
在研究代码后,QueueMessageHandler 会查找所有 SQSListener 注释的方法,并将它们都配置为相同的属性。这包括每个批处理配置的最大消息,我们希望每个侦听器有所不同。
我们是否需要自定义QueueMessageHandler,还是有更合适的方法来做到这一点?
我们有一个用例,其中我们的一些侦听器需要具有不同的消息执行器线程数。或者更确切地说,一些队列侦听器需要比其他队列侦听器更少的并发消息处理。
在研究代码后,QueueMessageHandler 会查找所有 SQSListener 注释的方法,并将它们都配置为相同的属性。这包括每个批处理配置的最大消息,我们希望每个侦听器有所不同。
我们是否需要自定义QueueMessageHandler,还是有更合适的方法来做到这一点?