Hi, i get the following Errormessage:
rg.jboss.mq.SpyJMSException: Cannot get the Queue from the provider; - nested
throwable: (javax.jms.JMSException: This destination does not exist !)
|
| at org.jboss.mq.SpyConnection.createQueue(SpyConnection.java:258)
|
| at org.jboss.mq.SpySession.createQueue(SpySession.java:783)
|
| at jms.Client1.setLogEntry(Client1.java:48)
|
| at jms.start.main(start.java:17)
|
| Caused by: javax.jms.JMSException: This destination does not exist !
|
| at
org.jboss.mq.server.JMSDestinationManager.createQueue(JMSDestinationManager.java:678)
|
| at
org.jboss.mq.server.JMSServerInterceptorSupport.createQueue(JMSServerInterceptorSupport.java:149)
|
| at
org.jboss.mq.server.TracingInterceptor.createQueue(TracingInterceptor.java:314)
|
| at org.jboss.mq.server.JMSServerInvoker.createQueue(JMSServerInvoker.java:149)
|
| at
org.jboss.mq.il.uil2.ServerSocketManagerHandler.handleMsg(ServerSocketManagerHandler.java:111)
|
| at
org.jboss.mq.il.uil2.SocketManager$ReadTask.handleMsg(SocketManager.java:356)
|
| at org.jboss.mq.il.uil2.msgs.BaseMsg.run(BaseMsg.java:377)
|
| at
EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(PooledExecutor.java:748)
|
| at java.lang.Thread.run(Thread.java:534)
|
| Exception in thread "main"
after i hava run this code:
| package jms;
|
| import java.util.Properties;
|
| import javax.jms.Message;
| import javax.jms.Queue;
| import javax.jms.QueueConnection;
| import javax.jms.QueueConnectionFactory;
| import javax.jms.QueueReceiver;
| import javax.jms.QueueSender;
| import javax.jms.QueueSession;
| import javax.jms.Session;
| import javax.jms.TextMessage;
| import javax.naming.Context;
| import javax.naming.InitialContext;
|
| public class Client1
|
| {
| private static final String QUEUE_CONNECTION_FACTORY="ConnectionFactory";
| private static Queue queue = null;
|
| public static void main(String[] args) throws Exception
| {
| }
| public void setLogEntry(String msg, String name) throws Exception
| {
|
| log.info("Creating jndi context - alternatively use a jndi.properties");
| Properties properties = new Properties();
| properties.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
| properties.put(Context.URL_PKG_PREFIXES, "org.jnp.interfaces");
| properties.put(Context.PROVIDER_URL, "localhost");
| InitialContext ctx = new InitialContext(properties);
|
| log.info("Looking up connection factory");
| QueueConnectionFactory qcf = (QueueConnectionFactory)
ctx.lookup("UIL2ConnectionFactory");
|
|
| log.info("Creating connection");
| QueueConnection qc = qcf.createQueueConnection();
| try
| {
| log.info("Creating session");
| QueueSession qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
|
| log.info("Creating Queue");
| this.queue = qs.createQueue(name);
|
| log.info("Creating sender with Queue: "+name);
| QueueSender sender = qs.createSender(queue);
|
|
| log.info("Creating message");
| TextMessage message = qs.createTextMessage(msg);
|
| log.info("Sending message");
| sender.send(message);
| }
| finally
| {
| qc.close();
| }
| }
|
| public String getLogEntry(String name) throws Exception
| {
|
| log.info("Creating jndi context - alternatively use a jndi.properties");
| Properties properties = new Properties();
| properties.put(Context.INITIAL_CONTEXT_FACTORY,
| "org.jnp.interfaces.NamingContextFactory");
| properties.put(Context.URL_PKG_PREFIXES, "org.jnp.interfaces");
| properties.put(Context.PROVIDER_URL, "localhost");
| InitialContext ctx = new InitialContext(properties);
|
|
|
| log.info("Looking up connection factory");
| QueueConnectionFactory qcf = (QueueConnectionFactory) ctx.lookup(
| "UIL2ConnectionFactory");
|
| log.info("Creating connection");
| QueueConnection qc = qcf.createQueueConnection();
| try
| {
|
| log.info("Creating session");
| QueueSession qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
|
|
|
| log.info("Creating receiver");
| QueueReceiver receiver = qs.createReceiver(this.queue);
|
| log.info("Try to receive message, it will not work");
| Message received = receiver.receiveNoWait();
| if (received != null)
| throw new RuntimeException(
| "Maybe you forget to clear the queue before running this test?");
|
| log.info("You have to start the connection before receiving messages");
| qc.start();
|
| log.info("This receive will work");
| received = receiver.receive();
|
| log.info("Got message: " + received);
| return received.getStringProperty("text");
| }
| finally
| {
| qc.close();
| }
|
|
| }
|
|
| }
|
Where is my mistake ?
Thanks!
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3844639#3844639
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3844639
-------------------------------------------------------
SF.Net email is sponsored by Shop4tech.com-Lowest price on Blank Media
100pk Sonic DVD-R 4x for only $29 -100pk Sonic DVD+R for only $33
Save 50% off Retail on Ink & Toner - Free Shipping and Free Gift.
http://www.shop4tech.com/z/Inkjet_Cartridges/9_108_r285
_______________________________________________
JBoss-user mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-user
