mirror of https://github.com/apache/activemq.git
Fix test failure
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1487607 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
067660ce88
commit
97e1edc20c
|
@ -142,7 +142,15 @@ public class PropertyExpression implements Expression {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Object evaluate(Message message) {
|
public Object evaluate(Message message) {
|
||||||
return message.getUserID();
|
Object userId = message.getUserID();
|
||||||
|
if (userId == null) {
|
||||||
|
try {
|
||||||
|
userId = message.getProperty("JMSXUserID");
|
||||||
|
} catch (IOException e) {
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return userId;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
JMS_PROPERTY_EXPRESSIONS.put("JMSXGroupSeq", new SubExpression() {
|
JMS_PROPERTY_EXPRESSIONS.put("JMSXGroupSeq", new SubExpression() {
|
||||||
|
|
Loading…
Reference in New Issue