发送者与交换机

• 发送者与交换机的确认机制confirm与Return

confirm

• Ack

  • 消息被broker接受

• Nack

  • 消息没有被broker接受

Return

• 消息被broker接受，可以没有对应的queue，所有返回给生产者

代码

channel.addConfirmListener(new ConfirmListener() {
           @Override
           public void handleAck(long l, boolean b) throws IOException {
               System.out.println("消息被broker接受"+l);
           }
           @Override
               public void handleNack(long l, boolean b) throws IOException {
               System.out.println("消息没有被broker接受"+l);
           }
       });
       channel.addReturnListener((i)->{
           System.out.println("+++++++++"+new String(i.getBody())+"  code:"+i.getReplyCode()+"  mianshi:"+i.getReplyText()+"   jiaohuangji:"+i.getExchange()+"   luyoukey:"+i.getRoutingKey());
       });