RabbitMQ删除队列无法释放连接

Question

 if(!con.isConnected()){
        log.error("Not connected !!!");

        return false;
}
con.getChannel().basicPublish("",queueName, MessageProperties.PERSISTENT_BASIC, bytes)

null

结果：队列已从RabbitMQ GUI中删除，但当我试图通过已删除的RabbitMQ队列发送消息时，连接仍然有效。(con.isConnected()==true)我需要找到一种方法来侦听队列，如果它被删除，我不应该向已删除的队列发送任何消息。

注意：删除队列后，我不会重新启动RabbitMQ。

渠道创建：

 channel = connection.createChannel();
 channel.queueDeclare(prop.getQueueName(), true, false, false, null);

ConnectionFactory cf = new ConnectionFactory();
    cf.setUsername("guest");
    cf.setPassword("guest");
    cf.setHost("localhost");
    cf.setPort(5672);
    cf.setAutomaticRecoveryEnabled(true);
    cf.setConnectionTimeout(10000);
    cf.setNetworkRecoveryInterval(10000);
    cf.setTopologyRecoveryEnabled(true);
    cf.setRequestedHeartbeat(5);
    Connection connection = cf.newConnection();

    channel = connection.createChannel();
    channel.queueDeclare("test", true, false, false, null);
    channel.exchangeDeclare("testExchange", "direct",true);
    channel.queueBind("test", "testExchange", "testRoutingKey");

    connection.addShutdownListener(new ShutdownListener() {

        @Override
        public void shutdownCompleted(ShutdownSignalException cause) {
            System.out.println("test"+cause);
        }
    });

正在发送消息：

            channel.basicPublish("testExchange", "testRoutingKey", null,messageBodyBytes);

Answer 1

来自RabbitMQ google

AMQP 0-9-1中的消息不发布到队列；它们被发布到交换，从那里它们被路由到队列（或另一个交换）或不被路由到队列（或另一个交换）。[1]Basic.Publish从设计上讲是一种完全异步的协议方法：除非您提出要求，否则不会有任何响应[2]。如果定义返回侦听器并将强制标志设置为true，则无法路由的消息可以返回到发布服务器。请注意，publisher确认和强制标志/返回是正交的，一个并不意味着另一个。

定义返回监听器和设置强制标志true解决了我的问题。如果没有路由任何消息，我可以使用ReturnListener捕获它们，并将它们添加到我的持久化队列中，以便在系统变为活动时发送另一个时间。