Author: rgodfrey
Date: Mon Jan 4 20:40:11 2016
New Revision: 1722961
URL: http://svn.apache.org/viewvc?rev=1722961&view=rev
Log:
QPID-6969 : commit client change accidentallly left out of last commit
Modified:
qpid/java/trunk/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java
Modified:
qpid/java/trunk/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java?rev=1722961&r1=1722960&r2=1722961&view=diff
==============================================================================
---
qpid/java/trunk/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java
(original)
+++
qpid/java/trunk/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java
Mon Jan 4 20:40:11 2016
@@ -23,6 +23,7 @@ import org.slf4j.LoggerFactory;
import org.apache.qpid.AMQInternalException;
import org.apache.qpid.client.message.AbstractJMSMessage;
import org.apache.qpid.filter.FilterableMessage;
+import org.apache.qpid.filter.JMSMessagePropertyExpression;
import org.apache.qpid.filter.SelectorParsingException;
import org.apache.qpid.filter.selector.ParseException;
import org.apache.qpid.filter.selector.SelectorParser;
@@ -53,7 +54,9 @@ public class JMSSelectorFilter implement
}
try
{
- _matcher = new SelectorParser().parse(selector);
+ SelectorParser<FilterableMessage> selectorParser = new
SelectorParser<>();
+
selectorParser.setPropertyExpressionFactory(JMSMessagePropertyExpression.FACTORY);
+ _matcher = selectorParser.parse(selector);
}
catch (ParseException e)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
