强制手动act

abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/mq/GenerateCodeConsumer.java

@@ -137,6 +137,10 @@ public class GenerateCodeConsumer {
 	@RabbitHandler
 	@RabbitListener(queues = GenerateCodeConsumer.GENERATE_CODE_BY_REPERTORY_QUEUE)
 	public void onMessage(String id, Message message, Channel channel) {
+		// 手工ack
+		Long deliveryTag = (Long)message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);
+		channel.basicAck(deliveryTag, false);
+
 		//判断rabbit消息是否为空
 		if(StringUtils.isEmpty(id)){
 			throw new BusinessException("队列监听数据为空！");
@@ -166,8 +170,8 @@ public class GenerateCodeConsumer {
 			qrPackageService.failedRollback(qrPackage);
 		} finally {
 			// 手工ack
-			Long deliveryTag = (Long)message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);
-			channel.basicAck(deliveryTag, false);
+//			Long deliveryTag = (Long)message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);
+//			channel.basicAck(deliveryTag, false);
 		}
 	}