diff options
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index 9c30b59b83..51617d57df 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java @@ -35,6 +35,7 @@ import org.apache.qpidity.QpidException; import org.apache.qpidity.filter.MessageFilter; import org.apache.qpidity.filter.JMSSelectorFilter; +import javax.jms.InvalidSelectorException; import javax.jms.JMSException; import javax.jms.MessageListener; import java.io.IOException; @@ -91,7 +92,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By } catch (QpidException e) { - throw new JMSException("cannot create consumer because of selector issue"); + throw new InvalidSelectorException("cannot create consumer because of selector issue"); } if (destination instanceof AMQQueue) { |