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.
