JMSException: Queue does not exist

[sarge <ag...@gmail.com>]

I want to create a basic MessageProducer who sends a message and
MessageConsumer who receives the message asynchronously. 

MessageProducer.java <http://pastebin.com/BNxqTXW6>  

MessageConsumer.java <http://pastebin.com/Ctj5M3gP>  

My ActiveMQServer as a broker.

Server.java <http://pastebin.com/RUZ5ZiZx>  

When I run this code:

main <http://pastebin.com/iJNK5FPg>  

I get this error messages:

/ Caught: javax.jms.JMSException: AMQ119017: Queue jms.queue.TEST.FOO does
not exist
javax.jms.JMSException: AMQ119017: Queue jms.queue.TEST.FOO does not exist
    at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:54)
    at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1405)
    at
org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1925)
    at
org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:275)
    at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1157)
    at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1101)
    at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1014)
    at
org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:987)
    at activemq.test.MessageConsumer.<init>(MessageConsumer.java:36)
    at activemq.test.AppMain.main(AppMain.java:17)
Caused by: ActiveMQNonExistentQueueException[errorType=QUEUE_DOES_NOT_EXIST
message=AMQ119017: Queue jms.queue.TEST.FOO does not exist]
    at
org.apache.activemq.core.server.impl.ServerSessionImpl.createConsumer(ServerSessionImpl.java:448)
    at
org.apache.activemq.core.protocol.openwire.amq.AMQServerSession.createConsumer(AMQServerSession.java:326)
    at
org.apache.activemq.core.protocol.openwire.amq.AMQConsumer.init(AMQConsumer.java:138)
    at
org.apache.activemq.core.protocol.openwire.amq.AMQSession.createConsumer(AMQSession.java:144)
    at
org.apache.activemq.core.protocol.openwire.OpenWireProtocolManager.addConsumer(OpenWireProtocolManager.java:544)
    at
org.apache.activemq.core.protocol.openwire.OpenWireConnection.processAddConsumer(OpenWireConnection.java:1118)
    at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:347)
    at
org.apache.activemq.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:272)
    at
org.apache.activemq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:678)
    at
org.apache.activemq.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:77)
    at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:332)
    at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:318)
    at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
    at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
    at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:507)
    at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:464)
    at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:378)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:350)
    at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
    at java.lang.Thread.run(Thread.java:745)/




--
View this message in context: http://activemq.2283324.n4.nabble.com/JMSException-Queue-does-not-exist-tp4696182.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.