Commit f37cea7b authored by yanzg's avatar yanzg

修复等待时间

parent a56dedd6
......@@ -108,7 +108,9 @@ public class BeanDao {
Properties queueProperties = amqpAdmin.getQueueProperties(queueName);
isCreateQueue = !queueProperties.isEmpty();
} catch (Exception ex) {
ex.printStackTrace();
if (ex != null) {
ex.printStackTrace();
}
}
if (isCreateQueue) {
YzgTimeout.timeOut(BeanDao.class, "创建队列" + queueName, () -> amqpAdmin.declareQueue(queueNew));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment