3 Replies Latest reply on Jan 18, 2010 6:42 AM by Vladimir Prodan

    Invalid Filter while creating a consumer on a temporaryqueue

    Vladimir Prodan Newbie

      Hi,

       

      I'm trying to create a temporary queue and after the creation I want to create a consumer on it and this is throwing an exception "Invalid Filter".

      The code is like this:

       

                  int replyAddressValue = replyAddressCounter.getAndIncrement();
                  replyAddress = subject + UUID.randomUUID().toString()+"."+replyAddressValue;
                  session.createTemporaryQueue(replyAddress, replyAddress);
                  replyAddresses.put(subject, replyAddress);
                  replyConsumer = session.createConsumer(replyAddress, replyAddress);
                  replyConsumers.put(subject, replyConsumer);
                  replyConsumer.setMessageHandler(new CallbackHandler());

       

      The exception is thrown on createConsumer like bellow.

      Could someone help me with a hint what's wrong here?

      Thank you!

       

      Regards,

      Vladimir

       

      #################

       

      HornetQException[errorCode=103 message=Invalid filter: getCompanybc4e24cc-cdc1-430b-8eb3-6b13e2de3d7d.0]

       


      SEVERE: Invalid filter
      org.hornetq.core.filter.impl.ParseException: Encountered "- 8140 - 42 a7" at line 1, column 19.
      Was expecting one of:
          <EOF>
          "AND" ...
          "OR" ...
          "IS" ...
          "NOT" ...
          "IN" ...
          "LIKE" ...
          "=" ...
          "<>" ...
          "*" ...
          "/" ...
          "+" ...
          "-" "+" ...
          "-" "-" ...
          "-" <FLOATING_POINT_LITERAL> ...
          "-" <INTEGER_LITERAL> "*" ...
          "-" <INTEGER_LITERAL> "/" ...
          "-" <INTEGER_LITERAL> "+" ...
          "-" <INTEGER_LITERAL> "-" "+" ...
          "-" <INTEGER_LITERAL> "-" "-" ...
          "-" <INTEGER_LITERAL> "-" <FLOATING_POINT_LITERAL> ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "*" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "/" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "+" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "-" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "=" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "<>" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> ">" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> ">=" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "<" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "<=" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "NOT" ...
          "-" <INTEGER_LITERAL> "-" <INTEGER_LITERAL> "BETWEEN" ...

       


         
              at org.hornetq.core.filter.impl.FilterParser.generateParseException(FilterParser.java:1472)
              at org.hornetq.core.filter.impl.FilterParser.jj_consume_token(FilterParser.java:1352)
              at org.hornetq.core.filter.impl.FilterParser.expression(FilterParser.java:107)
              at org.hornetq.core.filter.impl.FilterParser.parse(FilterParser.java:59)
              at org.hornetq.core.filter.impl.FilterParser.parse(FilterParser.java:39)
              at org.hornetq.core.filter.impl.FilterImpl.<init>(FilterImpl.java:106)
              at org.hornetq.core.filter.impl.FilterImpl.createFilter(FilterImpl.java:94)
              at org.hornetq.core.server.impl.ServerSessionImpl.handleCreateConsumer(ServerSessionImpl.java:356)
              at org.hornetq.core.server.impl.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:127)
              at org.hornetq.core.remoting.impl.ChannelImpl.handlePacket(ChannelImpl.java:466)
              at org.hornetq.core.remoting.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:423)
              at org.hornetq.core.remoting.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:389)
              at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:432)
              at org.hornetq.integration.transports.netty.HornetQChannelHandler.messageReceived(HornetQChannelHandler.java:67)
              at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:98)
              at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:560)
              at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:796)
              at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:358)
              at org.hornetq.integration.transports.netty.HornetQFrameDecoder2.decode(HornetQFrameDecoder2.java:171)
              at org.hornetq.integration.transports.netty.HornetQFrameDecoder2.messageReceived(HornetQFrameDecoder2.java:136)
              at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
              at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:560)
              at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:555)
              at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:345)
              at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:332)
              at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:323)
              at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:275)
              at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:196)
              at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
              at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46)
              at org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run(VirtualExecutorService.java:179)
              at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
              at java.lang.Thread.run(Thread.java:619)