上传文件 加密 不能打开问题 修改MQ
This commit is contained in:
@@ -71,10 +71,10 @@ public class SendConvertMQService {
|
|||||||
|
|
||||||
private static final Logger logger = LoggerFactory.getLogger(SendConvertMQService.class);
|
private static final Logger logger = LoggerFactory.getLogger(SendConvertMQService.class);
|
||||||
|
|
||||||
// @RabbitListener(bindings = @QueueBinding(
|
@RabbitListener(bindings = @QueueBinding(
|
||||||
// value = @Queue(value = "createConvertStandMQ_SQ_GSAR_RELEASE", durable = "true"),
|
value = @Queue(value = "createConvertStandMQ_SQ_GSAR_RELEASE", durable = "true"),
|
||||||
// exchange = @Exchange(value = "convert-exchange_SQ_GSAR_RELEASE", ignoreDeclarationExceptions = "true"),
|
exchange = @Exchange(value = "convert-exchange_SQ_GSAR_RELEASE", ignoreDeclarationExceptions = "true"),
|
||||||
// key = "convert-key_SQ_GSAR_RELEASE"))
|
key = "convert-key_SQ_GSAR_RELEASE"))
|
||||||
public void createMQ(Message message, Channel channel) throws Exception{
|
public void createMQ(Message message, Channel channel) throws Exception{
|
||||||
try{
|
try{
|
||||||
try{
|
try{
|
||||||
|
|||||||
Reference in New Issue
Block a user