Map<String, Object> arguments = new HashMap<>();
arguments.put("x-max-priority", 10);    //设置优先级队列
channel.queueDeclare(QUEUE_NAME, false, false, false, arguments);
for (int i = 1; i < 11; i++){ 

String message = "info" + i;
if (i == 7) { 
   //设置消息的优先级
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().priority(7).build();
channel.basicPublish("",QUEUE_NAME,properties,message.getBytes());
}else { 

channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
}
}