博客

AMQP.BasicProperties 提供了一个构造器，可以通过builder() 来设置一些属性；

可以通过AMQP.BasicProperties 来设置消息的一些属性

Map<String, Object> headers = new HashMap<String, Object>();
            headers.put("my1", "1111");
            headers.put("my2", "2222");

 AMQP.BasicProperties properties = new AMQP.BasicProperties().builder()
                    .deliveryMode(2) // 传送方式
                    .contentEncoding("UTF-8") // 编码方式
                    .expiration("10000") // 过期时间
                    .headers(headers) //自定义属性
                    .build();

之前我们的properties 都没有进行设置，
channel.basicPublish("", "test001", properties, msg.getBytes());

具体api

http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.1.3/rabbitmq-java-client-javadoc-3.1.3/com/rabbitmq/client/AMQP.BasicProperties.html