Commit e62e5f0c authored by Nicolas Tachker's avatar Nicolas Tachker
Browse files

Used JoramDestinationName instead of JMSDestinationName in message property for the interceptors.

parent 4c4daac2
...@@ -877,7 +877,7 @@ public class Queue extends Destination implements QueueMBean, BagSerializer { ...@@ -877,7 +877,7 @@ public class Queue extends Destination implements QueueMBean, BagSerializer {
for (Iterator msgs = not.getMessages().iterator(); msgs.hasNext();) { for (Iterator msgs = not.getMessages().iterator(); msgs.hasNext();) {
org.objectweb.joram.shared.messages.Message message = (org.objectweb.joram.shared.messages.Message) msgs.next(); org.objectweb.joram.shared.messages.Message message = (org.objectweb.joram.shared.messages.Message) msgs.next();
// set the destination name // set the destination name
message.setProperty("JMSDestinationName", getName()); message.setProperty("JoramDestinationName", getName());
// interceptors process // interceptors process
org.objectweb.joram.shared.messages.Message m = processInterceptors(message); org.objectweb.joram.shared.messages.Message m = processInterceptors(message);
if (m == null) { if (m == null) {
...@@ -1448,7 +1448,7 @@ public class Queue extends Destination implements QueueMBean, BagSerializer { ...@@ -1448,7 +1448,7 @@ public class Queue extends Destination implements QueueMBean, BagSerializer {
// get the shared message // get the shared message
org.objectweb.joram.shared.messages.Message message = msg.getFullMessage(); org.objectweb.joram.shared.messages.Message message = msg.getFullMessage();
// set the destination name // set the destination name
message.setProperty("JMSDestinationName", getName()); message.setProperty("JoramDestinationName", getName());
// interceptors process // interceptors process
org.objectweb.joram.shared.messages.Message m = processInterceptors(message); org.objectweb.joram.shared.messages.Message m = processInterceptors(message);
if (m == null) { if (m == null) {
......
...@@ -597,7 +597,7 @@ public class Topic extends Destination implements TopicMBean { ...@@ -597,7 +597,7 @@ public class Topic extends Destination implements TopicMBean {
while (it.hasNext()) { while (it.hasNext()) {
Message m = (Message) it.next(); Message m = (Message) it.next();
// set the destination name to the message // set the destination name to the message
m.setProperty("JMSDestinationName", getName()); m.setProperty("JoramDestinationName", getName());
message = processInterceptors(m); message = processInterceptors(m);
if (message != null) { if (message != null) {
newMessages.add(message); newMessages.add(message);
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment