Invalid Filter while creating a consumer on a temporaryqueue
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)
