Github user toddbaert commented on the issue:

    https://github.com/apache/activemq-artemis/pull/1701
  
    @clebertsuconic @michaelandrepearce 
    
    The problem seems to me to be pretty simple:
    
    in ClusterConnectionBridge.beforeForward(Message message, SimpleString 
forwardingAddress), we call super.beforeForward(message, **null**). The is why 
we lose the address. This code path is executed when broker1 forwards an AMQP 
message to broker2. This is why we will only see this in a cluster, when a 
producer sends a message to broker1 and a consumer is listening on broker2.



---

Reply via email to