Author: rgodfrey Date: Mon Apr 16 12:11:22 2012 New Revision: 1326569 URL: http://svn.apache.org/viewvc?rev=1326569&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/TopicSubscriberImpl.java Modified: qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.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/TopicSubscriberImpl.java?rev=1326569&r1=1326568&r2=1326569&view=diff ============================================================================== --- qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java (original) +++ qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java Mon Apr 16 12:11:22 2012 @@ -91,9 +91,7 @@ public class TopicSubscriberImpl extends catch (AmqpErrorException e) { org.apache.qpid.amqp_1_0.type.transport.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: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org