|
@@ -86,7 +86,7 @@ public class SceneListener {
|
|
|
* @throws Exception the io exception 这里异常需要处理
|
|
|
*/
|
|
|
@RabbitListener(
|
|
|
- queuesToDeclare = @Queue("${queue.scene-queue}"),concurrency = "5"
|
|
|
+ queuesToDeclare = @Queue("${queue.scene-queue}"),concurrency = "2"
|
|
|
)
|
|
|
public void sceneQueue(Channel channel, Message message) throws IOException {
|
|
|
if (ObjectUtils.isEmpty(message.getBody())) {
|