Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1701#discussion_r155936916
--- Diff:
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
---
@@ -608,7 +608,11 @@ public AMQPMessage setAddress(String address) {
@Override
public AMQPMessage setAddress(SimpleString address) {
- return setAddress(address.toString());
+ if (address != null) {
+ return setAddress(address.toString());
+ } else {
+ return null;
--- End diff --
shouldn't this be:
return setAddress(null);
????
---
