Author: rgodfrey
Date: Mon Apr 16 11:02:33 2012
New Revision: 1326558
URL: http://svn.apache.org/viewvc?rev=1326558&view=rev
Log:
QPID-3949 : [Java AMQP 1.0] Fix descriptors on filters
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageConsumerImpl.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageConsumerImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageConsumerImpl.java?rev=1326558&r1=1326557&r2=1326558&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageConsumerImpl.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageConsumerImpl.java
Mon Apr 16 11:02:33 2012
@@ -133,9 +133,7 @@ public class MessageConsumerImpl impleme
catch (AmqpErrorException e)
{
Error error = e.getError();
- if(AmqpError.INVALID_FIELD.equals(error.getCondition())
- && error.getInfo() != null &&
Symbol.valueOf("filter").equals(error.getInfo().get(Symbol.valueOf
- ("field"))))
+ if(AmqpError.INVALID_FIELD.equals(error.getCondition()))
{
throw new InvalidSelectorException(e.getMessage());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
