You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by mtaylor <gi...@git.apache.org> on 2018/01/17 10:26:28 UTC
[GitHub] activemq-artemis pull request #1782: ARTEMIS-1612 Fix message redistribution...
GitHub user mtaylor opened a pull request:
https://github.com/apache/activemq-artemis/pull/1782
ARTEMIS-1612 Fix message redistribution for prefixed addresses
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mtaylor/activemq-artemis ARTEMIS-1612
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/activemq-artemis/pull/1782.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1782
----
commit 06c9f19fb772b5861f127207a19e375381749f5b
Author: Martyn Taylor <mt...@...>
Date: 2018-01-17T10:24:20Z
ARTEMIS-1612 Fix message redistribution for prefixed addresses
----
---
[GitHub] activemq-artemis pull request #1782: ARTEMIS-1612 Fix message redistribution...
Posted by clebertsuconic <gi...@git.apache.org>.
Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1782#discussion_r162100927
--- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/PostOfficeImpl.java ---
@@ -892,7 +892,7 @@ public MessageReference reroute(final Message message, final Queue queue, final
// as described on https://issues.jboss.org/browse/JBPAPP-6130
Message copyRedistribute = message.copy(storageManager.generateID());
- Bindings bindings = addressManager.getBindingsForRoutingAddress(message.getAddressSimpleString());
+ Bindings bindings = addressManager.getBindingsForRoutingAddress(originatingQueue.getAddress());
--- End diff --
nice!!! easy and simple fix!!!!
---
[GitHub] activemq-artemis pull request #1782: ARTEMIS-1612 Fix message redistribution...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/activemq-artemis/pull/1782
---