diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java index 0aa837a6..ac385e22 100644 --- a/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java +++ b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java @@ -71,10 +71,10 @@ public class SendConvertMQService { private static final Logger logger = LoggerFactory.getLogger(SendConvertMQService.class); - @RabbitListener(bindings = @QueueBinding( - value = @Queue(value = "createConvertStandMQ_SQ_GSAR_RELEASE", durable = "true"), - exchange = @Exchange(value = "convert-exchange_SQ_GSAR_RELEASE", ignoreDeclarationExceptions = "true"), - key = "convert-key_SQ_GSAR_RELEASE")) +// @RabbitListener(bindings = @QueueBinding( +// value = @Queue(value = "createConvertStandMQ_SQ_GSAR_RELEASE", durable = "true"), +// exchange = @Exchange(value = "convert-exchange_SQ_GSAR_RELEASE", ignoreDeclarationExceptions = "true"), +// key = "convert-key_SQ_GSAR_RELEASE")) public void createMQ(Message message, Channel channel) throws Exception{ try{ try{