java - rabbitmq 客户端 AMQP.BasicProperties 如何设置 headers？

Question

我的 Delivery 对象具有 BasicProperties。但是 basicproprieties header 内部为空。我需要向 header 添加一个值。我为此使用了构建器模式，因为没有 setter 。

                Integer retryIndex = 1;

                if (delivery.getProperties().getHeaders() == null) {
                    delivery.getProperties().builder().headers(new HashMap<>()).build();
                }

                if (delivery.getProperties().getHeaders().containsKey(KEY_RETRY_COUNT)){
                    retryIndex = (Integer) delivery.getProperties().getHeaders().get(KEY_RETRY_COUNT);
                    retryIndex++;
                }

                delivery.getProperties().getHeaders().put(KEY_RETRY_COUNT, retryIndex);

当我运行代码第二个 if 条件 if (delivery.getProperties().getHeaders().containsKey(KEY_RETRY_COUNT)) 获取 nullPointEreException 时。有人可以为此提供帮助。

Answer 1

    Delivery del = null;

                    if (delivery.getProperties().getHeaders() == null) {
                        Map<String, Object> header = new HashMap<>();
                        header.put(KEY_RETRY_COUNT, retryIndex);
                        delivery.getProperties().builder().headers(header).build();

                        del = new Delivery(delivery.getEnvelope(),
                                           new AMQP.BasicProperties().builder().headers(header).build(),
                                           delivery.getBody());
}

这里我创建了一个新的 Delivery 对象并使用构造函数来设置属性。