Weblogic 10.3.2 queue connection factory and queue creation

[Lavanya Halliwell]

How do you set up a queue connection factory and queue in weblogic?

and then, how do you access that queue with your java code?

I tried to create this in weblogic, and then in JDeveloper I created a small code:

  

package testJMSexample1;

import java.util.Hashtable;
import javax.naming.*;
import javax.jms.*;

public class WeblogicClient {

  private static InitialContext ctx = null;
  private static QueueConnectionFactory qcf = null;
  private static QueueConnection qc = null;
  private static QueueSession qsess = null;
  private static Queue q = null;
  private static QueueSender qsndr = null;
  private static TextMessage message = null;
  private static final String DEFAULT_QCF_NAME = "jms/CFTest";
  private static final String DEFAULT_QUEUE_NAME = "jms/QTest";
  private static final String DEFAULT_URL = "t3://localhost:7101";
  private static final String DEFAULT_USER = "weblogic";
  private static final String DEFAULT_PASSWORD =  "weblogic1";

  public WeblogicClient() {
    super();
  }

  public static void sendMessage(String messageText) {
    sendMessage(DEFAULT_URL,
    DEFAULT_USER,
    DEFAULT_PASSWORD,
    DEFAULT_QCF_NAME,
    DEFAULT_QUEUE_NAME,
    messageText);
  }

  public static void sendMessage(String url, String user, String password,
                                 String cf, String queue, String messageText) {
    // create InitialContext
    Hashtable properties = new Hashtable();
    properties.put(Context.INITIAL_CONTEXT_FACTORY,
                   "weblogic.jndi.WLInitialContextFactory");
    properties.put(Context.PROVIDER_URL, url);
    properties.put(Context.SECURITY_PRINCIPAL, user);
    properties.put(Context.SECURITY_CREDENTIALS, password);

    try {
      ctx = new InitialContext(properties);
    } catch (NamingException ne) {
      ne.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got InitialContext " + ctx.toString());

    // create QueueConnectionFactory
    try {
      qcf = (QueueConnectionFactory)ctx.lookup(cf);
    } catch (NamingException ne) {
      ne.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got QueueConnectionFactory " + qcf.toString());

    // create QueueConnection
    try {
      qc = qcf.createQueueConnection();
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got QueueConnection " + qc.toString());

    // create QueueSession
    try {
      qsess = qc.createQueueSession(false, 0);
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got QueueSession " + qsess.toString());

    // lookup Queue
    try {
      q = (Queue)ctx.lookup(queue);
    } catch (NamingException ne) {
      ne.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got Queue " + q.toString());

    // create QueueSender
    try {
      qsndr = qsess.createSender(q);
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got QueueSender " + qsndr.toString());

    // create TextMessage
    try {
      message = qsess.createTextMessage();
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Got TextMessage " + message.toString());

    // set message text in TextMessage
    try {
      message.setText(messageText);
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Set text in TextMessage " + message.toString());

    // send message
    try {
      qsndr.send(message);
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
      System.exit(0);
    }
    System.out.println("Sent message ");

    // clean up
    try {
      message = null;
      qsndr.close();
      qsndr = null;
      q = null;
      qsess.close();
      qsess = null;
      qc.close();
      qc = null;
      qcf = null;
      ctx = null;
    } catch (JMSException jmse) {
      jmse.printStackTrace(System.err);
    }
    System.out.println("Cleaned up and done.");
  }

  public static void main(String[] args) {
    sendMessage("test");
    sendMessage("t3://localhost:7101",
                "weblogic",
                "weblogic1",
                "jms/CFTest",
                "jms/QTest",
                "test");
  }

}

  

the problem I face is that I get the error:

  

C:\bea\jdk160_14_R27.6.5-32\bin\javaw.exe -client -classpath C:\jdeveloper\mywork\testJMS\testJMSexample1\classes;C:\NetBeansProjects\NETBEANS_JAR_FILES\lib\com.stc.jms.stcjms.jar;C:\NetBeansProjects\NETBEANS_JAR_FILES\lib\jms.jar;C:\NetBeansProjects\NETBEANS_JAR_FILES\lib\com.stc.jmsis.jar;C:\bea\modules\javax.jms_1.1.1.jar;C:\bea\wlserver_10.3\server\lib\aqapi.jar;C:\bea\modules\javax.transaction_1.0.0.0_1-1.jar;C:\bea\wlserver_10.3\server\lib\wlclient.jar;C:\bea\wlserver_10.3\server\lib\wljmxclient.jar;C:\bea\wlserver_10.3\server\lib\wljmsclient.jar;C:\bea\wlserver_10.3\server\lib\wlnmclient.jar;C:\bea\wlserver_10.3\server\lib\wlsafclient.jar -Djavax.net.ssl.trustStore=C:\bea\wlserver_10.3\server\lib\DemoTrust.jks testJMSexample1.WeblogicClient
Got InitialContext javax.naming.InitialContext@147c1db
javax.naming.NameNotFoundException: Exception in lookup.: `jms/CFTest' could not be found. [Root exception is weblogic.corba.cos.naming.NamingContextAnyPackage.NotFound: IDL:weblogic/corba/cos/naming/NamingContextAny/NotFound:1.0]
	at weblogic.corba.j2ee.naming.Utils.wrapNamingException(Utils.java:65)
	at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:289)
	at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:227)
	at javax.naming.InitialContext.lookup(InitialContext.java:392)
	at testJMSexample1.WeblogicClient.sendMessage(WeblogicClient.java:55)
	at testJMSexample1.WeblogicClient.sendMessage(WeblogicClient.java:27)
	at testJMSexample1.WeblogicClient.main(WeblogicClient.java:144)
Caused by: weblogic.corba.cos.naming.NamingContextAnyPackage.NotFound: IDL:weblogic/corba/cos/naming/NamingContextAny/NotFound:1.0
	at weblogic.corba.cos.naming.NamingContextAnyPackage.NotFoundHelper.read(NotFoundHelper.java:72)
	at weblogic.corba.cos.naming._NamingContextAnyStub.resolve_any(_NamingContextAnyStub.java:87)
	at weblogic.corba.j2ee.naming.ContextImpl.lookup(ContextImpl.java:267)
	... 5 more
Process exited with exit code 0.



  

I let JDeveloper start weblogic, so it runs on localhost:7101 with user/pass weblogic/weblogic1
I call my Queue connection factory: jms/CFTest (jndi name)
I call my queue : jms/QTest (jndi name)

[Joseph Antoine Raja]

Hi Lavanya,

To setup this JMS connection you should identify the WL version 8.1 (or) 9.2 and Later.

Because the Configuration model is totally different from WLS8 to WLS9

Assuming you are using WLS9 and later

1) create a JMS Server and target it to any WL servers
2) Create a JMS Module [ which is the collection of all customizable JMS components]
3) then inside the Module create a Connection Factory and Queue by specifying the necessary details [ JNDI name/ etc.. ]
4) target this components to the JMS server that you have created
5) Reboot the Admin / managed servers [ though this is not mandatory in WL9 this is highly recomended for clean configuration ]
6) once the server comes live check the JNDI tree whether the components are configured properly.

But I am not sure about the coding part.

[Shyam Ramath]

How you got this solved ?