The following article shows a simple usage of WebLogic JMS Point to Point feature using a Queue.
JMS supports two messaging models: point-to-point (PTP) and publish/subscribe (pub/sub). The messaging models are very similar, except for the following differences:
- PTP messaging model enables the delivery of a message to exactly one recipient.
- Pub/sub messaging model enables the delivery of a message to multiple recipients.
The point-to-point (PTP) messaging model enables one application to send a message to another. PTP messaging applications send and receive messages using named Queues. A queue sender (producer) sends a message to a specific queue. A queue receiver (consumer) receives messages from a specific queue.
The following figure illustrates PTP messaging.
Steps to configure JMS Point to Point Feature (JMS Queue)
1. Configure JMS Server
a. Login into the WebLogic Admin Console, navigate to Services –> Messaging –> JMS Servers.
JMS Server acts as a management containers for the queues and topics.
b. Create a JMS Server as below.
c. Target the JMS Server to any one of the WebLogic Servers.
2. Create JMS System Module to hold the Queues / Topics.
a. Navigate to Services –> Messaging –> JMS Modules from the left panel.
b. Target the JMS System Module to the server on which the JMS Server is targeted.
3. Create a Sub Deployment.
a. Click on the newly created JMS SystemModule and navigate to the SubDeployments tab
b. Target the Sub Deployment to the created JMS Server.
4. Create JMS Connection Factory.
a. Under the configuration tab of the JMS SystemModule, click New to add resources like Connection Factories, Queues,Topics.
b. Create a JMS Connection Factory, specify a JNDI name.
c. Target the Connection Factory to the Sub Deployment.
5. Create a JMS Queue (Point to Point Messaging Model)
a. Create a Queue from the configuration tab of the JMS SystemModule.
b. Target the Queue to the Sub Deployment.
c . Navigate to the JMS Resources page and you would see the Connection Factory and the JMS Queue created.
6. Testing the setup
a. Open command prompt, and set the class path.
Note: You can run the setDomainEnv script present under the <Domain>/bin folder
b. Compile and execute the below, QueueSend.java program to send a message to the queue.
********************************************************
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.util.Hashtable; import javax.jms.*; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; public class QueueSend { public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory"; public final static String JMS_FACTORY="CF1"; public final static String QUEUE="Queue1"; private QueueConnectionFactory qconFactory; private QueueConnection qcon; private QueueSession qsession; private QueueSender qsender; private Queue queue; private TextMessage msg; public void init(Context ctx, String queueName) throws NamingException, JMSException { qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY); qcon = qconFactory.createQueueConnection(); qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); queue = (Queue) ctx.lookup(queueName); qsender = qsession.createSender(queue); msg = qsession.createTextMessage(); qcon.start(); } public void send(String message) throws JMSException { msg.setText(message); qsender.send(msg); } public void close() throws JMSException { qsender.close(); qsession.close(); qcon.close(); } public static void main(String[] args) throws Exception { if (args.length != 1) { System.out.println("Usage: java examples.jms.queue.QueueSend WebLogicURL"); return; } InitialContext ic = getInitialContext(args[0]); QueueSend qs = new QueueSend(); qs.init(ic, QUEUE); readAndSend(qs); qs.close(); } private static void readAndSend(QueueSend qs) throws IOException, JMSException { BufferedReader msgStream = new BufferedReader(new InputStreamReader(System.in)); String line=null; boolean quitNow = false; do { System.out.print("Enter message ("quit" to quit): n"); line = msgStream.readLine(); if (line != null && line.trim().length() != 0) { qs.send(line); System.out.println("JMS Message Sent: "+line+"n"); quitNow = line.equalsIgnoreCase("quit"); } } while (! quitNow); } private static InitialContext getInitialContext(String url) throws NamingException { Hashtable<String,String> env = new Hashtable<String,String>(); env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY); env.put(Context.PROVIDER_URL, url); return new InitialContext(env); } }
********************************************************
java QueueSend t3://localhost:7001
c. Compile and execute the below QueueReceive.java program to retrieve the message from the queue.
***********************************************************
import java.util.Hashtable; import javax.jms.*; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; public class QueueReceive implements MessageListener { public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory"; public final static String JMS_FACTORY="CF1"; public final static String QUEUE="Queue1"; private QueueConnectionFactory qconFactory; private QueueConnection qcon; private QueueSession qsession; private QueueReceiver qreceiver; private Queue queue; private boolean quit = false; public void onMessage(Message msg) { try { String msgText; if (msg instanceof TextMessage) { msgText = ((TextMessage)msg).getText(); } else { msgText = msg.toString(); } System.out.println("Message Received: "+ msgText ); if (msgText.equalsIgnoreCase("quit")) { synchronized(this) { quit = true; this.notifyAll(); // Notify main thread to quit } } } catch (JMSException jmse) { System.err.println("An exception occurred: "+jmse.getMessage()); } } public void init(Context ctx, String queueName) throws NamingException, JMSException { qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY); qcon = qconFactory.createQueueConnection(); qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); queue = (Queue) ctx.lookup(queueName); qreceiver = qsession.createReceiver(queue); qreceiver.setMessageListener(this); qcon.start(); } public void close()throws JMSException { qreceiver.close(); qsession.close(); qcon.close(); } public static void main(String[] args) throws Exception { if (args.length != 1) { System.out.println("Usage: java examples.jms.queue.QueueReceive WebLogicURL"); return; } InitialContext ic = getInitialContext(args[0]); QueueReceive qr = new QueueReceive(); qr.init(ic, QUEUE); System.out.println("JMS Ready To Receive Messages (To quit, send a "quit" message)."); synchronized(qr) { while (! qr.quit) { try { qr.wait(); } catch (InterruptedException ie) {} } } qr.close(); } private static InitialContext getInitialContext(String url) throws NamingException { Hashtable<String,String> env = new Hashtable<String,String>(); env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY); env.put(Context.PROVIDER_URL, url); return new InitialContext(env); }}
***********************************************************
java QueueReceive t3://localhost:7001
Further Reading :
http://download.oracle.com/docs/cd/E12840_01/wls/docs103/jms/fund.html#wp1071729
Cheers,
Wonders Team. 🙂
This tutorial is really fantastic step by step guide. I had searched a lot in the internet for such kind of tutorial but finally thanks to Anandraj for this tutorial.
Appreciate your feedback!! It keeps us motivated to work harder.
Thank you, thank you! I was working for days trying to get something like this to work and it worked a treat!
Thanks Louise!
Hi,
This is a very helpful document. I followed the same steps and executed the QueueSend java code on the weblogic server box to post a msg to the weblogic server queue. It was successful. I am using weblogic server 10.3.0.4. However I am getting error while executing the same QueueSend java code from my local machine. I am able to get into the weblogic server url directly from my local machine, but if i use the url to execute this java program its giving error. Here is the error detail. Please help.
C:\jdk6update18>java QueueSend http://orraaomn.na.jmsmucker.com:7001
Jul 21, 2011 9:58:03 AM com.sun.corba.se.impl.legacy.connection.SocketFactoryCon
nectionImpl
WARNING: “IOP00410201: (COMM_FAILURE) Connection failure: socketType: IIOP_CLEAR
_TEXT; hostname: 10.1.3.167; port: 7001”
org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 201 completed: No
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectFailure(O
RBUtilSystemException.java:2200)
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectFailure(O
RBUtilSystemException.java:2221)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryConnectionImpl.(SocketFactoryConnectionImpl.java:73)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryContactInfoImpl.
createConnection(SocketFactoryContactInfoImpl.java:70)
at com.sun.corba.se.impl.protocol.CorbaClientRequestDispatcherImpl.begin
Request(CorbaClientRequestDispatcherImpl.java:152)
at com.sun.corba.se.impl.protocol.CorbaClientDelegateImpl.request(CorbaC
lientDelegateImpl.java:118)
at com.sun.corba.se.impl.protocol.CorbaClientDelegateImpl.non_existent(C
orbaClientDelegateImpl.java:231)
at org.omg.CORBA.portable.ObjectImpl._non_existent(ObjectImpl.java:137)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReferenceWithRetry(ORBHelp
er.java:633)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReference(ORBHelper.java:5
94)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContex
t(InitialContextFactoryImpl.java:85)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContex
t(InitialContextFactoryImpl.java:31)
at weblogic.jndi.WLInitialContextFactory.getInitialContext(WLInitialCont
extFactory.java:46)
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:6
67)
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:288
)
at javax.naming.InitialContext.init(InitialContext.java:223)
at javax.naming.InitialContext.(InitialContext.java:197)
at QueueSend.getInitialContext(QueueSend.java:143)
at QueueSend.main(QueueSend.java:89)
Caused by: java.net.ProtocolException: Tunneling result unspecified – is the HTT
P server at host: ‘10.1.3.167’ and port: ‘7001’ a WebLogic Server?
at weblogic.corba.client.http.TunneledSocketImpl.throwProtocolException(
TunneledSocketImpl.java:513)
at weblogic.corba.client.http.TunneledSocketImpl.connectInternal(Tunnele
dSocketImpl.java:253)
at weblogic.corba.client.iiop.BiDirSocketImpl.connect(BiDirSocketImpl.ja
va:355)
at weblogic.corba.client.iiop.BiDirSocketImpl.connect(BiDirSocketImpl.ja
va:139)
at weblogic.corba.client.http.TunneledSocketImpl.connect(TunneledSocketI
mpl.java:289)
at java.net.Socket.connect(Socket.java:525)
at java.net.Socket.connect(Socket.java:475)
at weblogic.corba.client.iiop.BiDirSocket.(BiDirSocket.java:22)
at weblogic.corba.client.http.TunneledSocket.(TunneledSocket.java:
31)
at weblogic.corba.client.http.TunneledSocketFactory.createSocket(Tunnele
dSocketFactory.java:91)
at weblogic.corba.client.iiop.BiDirORBSocketFactory.createSocket(BiDirOR
BSocketFactory.java:89)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryConnectionImpl.(SocketFactoryConnectionImpl.java:55)
… 16 more
Exception in thread “main” javax.naming.NamingException: Couldn’t connect to the
specified host : Tunneling result unspecified – is the HTTP server at host: ’10
.1.3.167′ and port: ‘7001’ a WebLogic Server? [Root exception is org.omg.CORBA.C
OMM_FAILURE: vmcid: SUN minor code: 201 completed: No]
at weblogic.corba.j2ee.naming.Utils.wrapNamingException(Utils.java:83)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReferenceWithRetry(ORBHelp
er.java:656)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReference(ORBHelper.java:5
94)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContex
t(InitialContextFactoryImpl.java:85)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContex
t(InitialContextFactoryImpl.java:31)
at weblogic.jndi.WLInitialContextFactory.getInitialContext(WLInitialCont
extFactory.java:46)
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:6
67)
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:288
)
at javax.naming.InitialContext.init(InitialContext.java:223)
at javax.naming.InitialContext.(InitialContext.java:197)
at QueueSend.getInitialContext(QueueSend.java:143)
at QueueSend.main(QueueSend.java:89)
Caused by: org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 201 completed:
No
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectFailure(O
RBUtilSystemException.java:2200)
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectFailure(O
RBUtilSystemException.java:2221)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryConnectionImpl.(SocketFactoryConnectionImpl.java:73)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryContactInfoImpl.
createConnection(SocketFactoryContactInfoImpl.java:70)
at com.sun.corba.se.impl.protocol.CorbaClientRequestDispatcherImpl.begin
Request(CorbaClientRequestDispatcherImpl.java:152)
at com.sun.corba.se.impl.protocol.CorbaClientDelegateImpl.request(CorbaC
lientDelegateImpl.java:118)
at com.sun.corba.se.impl.protocol.CorbaClientDelegateImpl.non_existent(C
orbaClientDelegateImpl.java:231)
at org.omg.CORBA.portable.ObjectImpl._non_existent(ObjectImpl.java:137)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReferenceWithRetry(ORBHelp
er.java:633)
… 10 more
Caused by: java.net.ProtocolException: Tunneling result unspecified – is the HTT
P server at host: ‘10.1.3.167’ and port: ‘7001’ a WebLogic Server?
at weblogic.corba.client.http.TunneledSocketImpl.throwProtocolException(
TunneledSocketImpl.java:513)
at weblogic.corba.client.http.TunneledSocketImpl.connectInternal(Tunnele
dSocketImpl.java:253)
at weblogic.corba.client.iiop.BiDirSocketImpl.connect(BiDirSocketImpl.ja
va:355)
at weblogic.corba.client.iiop.BiDirSocketImpl.connect(BiDirSocketImpl.ja
va:139)
at weblogic.corba.client.http.TunneledSocketImpl.connect(TunneledSocketI
mpl.java:289)
at java.net.Socket.connect(Socket.java:525)
at java.net.Socket.connect(Socket.java:475)
at weblogic.corba.client.iiop.BiDirSocket.(BiDirSocket.java:22)
at weblogic.corba.client.http.TunneledSocket.(TunneledSocket.java:
31)
at weblogic.corba.client.http.TunneledSocketFactory.createSocket(Tunnele
dSocketFactory.java:91)
at weblogic.corba.client.iiop.BiDirORBSocketFactory.createSocket(BiDirOR
BSocketFactory.java:89)
at com.sun.corba.se.impl.legacy.connection.SocketFactoryConnectionImpl.(SocketFactoryConnectionImpl.java:55)
… 16 more
Hi,
Can you try using the IP address of the machine instead of orraaomn.na.jmsmucker.com? Also try t3 instead of http. Let me know how it behaves.
Best Regards,
Divya
very good document
Thanks Gaurav. 🙂
Regards,
Anandraj
Its very very very useful… thanks a lot !!!!!!!!!!
Thanks for your appreciation Sudha!!
Very Use ful.. Thanks
This one was really good .. thanks guys
Thanks Jasheer…. that would help us to do better. 🙂
Cheers,
Anandraj
Thank you so much for this excellent article.. I could run both the examples and it cleared a bunch of doubts on WLS configuration for JMS.
thanks for your appreciation Bijay!
Its very very useful !!!
Thank you…
thanks Shankar!
very useful! i followed the steps and was able to test my application – all in 5 mins!!
Hi Rajiv,
Thanks for the appreciation.
Cheers,
Wonders team
excellent this is help full really
Thanks Ramesh for the appreciation.
Cheers,
Wonders team
Its wonderfull example of JMS
Hi, I use weblogic 12.1.2 but get the following complaints. Is there any idea?
Thanks
Xianhua
PS D:\temp> javac -cp “.;d:\eclipse\workspace\IntegrationService\lib\*” .\QueueSend.java
PS D:\temp> java -cp “.;d:\eclipse\workspace\IntegrationService\lib\*” QueueSend t3://10.8.72.5:7001
Jun 15, 2014 4:19:09 PM com.sun.corba.se.impl.orb.ORBImpl checkShutdownState
WARNING: “IOP01210228: (BAD_OPERATION) This ORB instance has been destroyed, so no operations can be performed on it”
org.omg.CORBA.BAD_OPERATION: vmcid: SUN minor code: 228 completed: No
at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbDestroyed(ORBUtilSystemException.java:586)
at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbDestroyed(ORBUtilSystemException.java:608)
at com.sun.corba.se.impl.orb.ORBImpl.checkShutdownState(ORBImpl.java:1329)
at com.sun.corba.se.impl.orb.ORBImpl.getThreadPoolManager(ORBImpl.java:2074)
at com.sun.corba.se.impl.transport.SelectorImpl.createListenerThread(SelectorImpl.java:444)
at com.sun.corba.se.impl.transport.SelectorImpl.registerForEvent(SelectorImpl.java:154)
at com.sun.corba.se.impl.transport.SocketOrChannelAcceptorImpl.accept(SocketOrChannelAcceptorImpl.java:271)
at com.sun.corba.se.impl.transport.ListenerThreadImpl.doWork(ListenerThreadImpl.java:97)
at com.sun.corba.se.impl.orbutil.threadpool.ThreadPoolImpl$WorkerThread.performWork(ThreadPoolImpl.java:490)
at com.sun.corba.se.impl.orbutil.threadpool.ThreadPoolImpl$WorkerThread.run(ThreadPoolImpl.java:519)
Exception in thread “main” javax.naming.NamingException: Couldn’t connect to the specified host : [Root exception is or
g.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 208 completed: Maybe]
at weblogic.corba.j2ee.naming.Utils.wrapNamingException(Utils.java:83)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReferenceWithRetry(ORBHelper.java:638)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReference(ORBHelper.java:582)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContext(InitialContextFactoryImpl.java:85)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContext(InitialContextFactoryImpl.java:31)
at weblogic.jndi.WLInitialContextFactory.getInitialContext(WLInitialContextFactory.java:46)
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:684)
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:307)
at javax.naming.InitialContext.init(InitialContext.java:242)
at javax.naming.InitialContext.(InitialContext.java:216)
at QueueSend.getInitialContext(QueueSend.java:73)
at QueueSend.main(QueueSend.java:46)
Caused by: org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 208 completed: Maybe
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectionAbort(ORBUtilSystemException.java:2400)
at com.sun.corba.se.impl.logging.ORBUtilSystemException.connectionAbort(ORBUtilSystemException.java:2418)
at com.sun.corba.se.impl.transport.SocketOrChannelConnectionImpl.readBits(SocketOrChannelConnectionImpl.java:372
)
at com.sun.corba.se.impl.transport.SocketOrChannelConnectionImpl.read(SocketOrChannelConnectionImpl.java:307)
at com.sun.corba.se.impl.transport.ReaderThreadImpl.doWork(ReaderThreadImpl.java:98)
at com.sun.corba.se.impl.orbutil.threadpool.ThreadPoolImpl$WorkerThread.performWork(ThreadPoolImpl.java:490)
at com.sun.corba.se.impl.orbutil.threadpool.ThreadPoolImpl$WorkerThread.run(ThreadPoolImpl.java:519)
Caused by: org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 211 completed: No
at com.sun.corba.se.impl.logging.ORBUtilSystemException.ioexceptionWhenReadingConnection(ORBUtilSystemException.
java:2484)
at com.sun.corba.se.impl.logging.ORBUtilSystemException.ioexceptionWhenReadingConnection(ORBUtilSystemException.
java:2502)
at com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase.readGIOPHeader(MessageBase.java:134)
at com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase.readGIOPMessage(MessageBase.java:116)
at com.sun.corba.se.impl.transport.CorbaContactInfoBase.createMessageMediator(CorbaContactInfoBase.java:171)
at com.sun.corba.se.impl.transport.SocketOrChannelConnectionImpl.readBits(SocketOrChannelConnectionImpl.java:332
)
… 4 more
Caused by: java.io.IOException: End-of-stream
at com.sun.corba.se.impl.transport.SocketOrChannelConnectionImpl.readFully(SocketOrChannelConnectionImpl.java:68
4)
at com.sun.corba.se.impl.transport.SocketOrChannelConnectionImpl.read(SocketOrChannelConnectionImpl.java:545)
at com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase.readGIOPHeader(MessageBase.java:130)
… 7 more
PS D:\temp> ^A
what is the java version your are compiling your client with?
Hello,
It’s neccesary to install Weblogic if i only want to send a message to a queue?
Thank you very much.
Ana
yes Ana..
Thank you very much, but if i don’t have to create nothing, why is necessary to install weblogic?
i’ve readen that to be a weblogic client it is necessary the wlfullclient.jar, this is true?
Thank you,
Ana
Hi Ana,
If you are a client, i.e Weblogic is installed somewhere else and you just need to send jms message to the queue/topic, then you don’t need to install weblogic locally.
You just need to have to necessary library ( wlfullclient.jar) to send the message to WLS.
Thanks,
Faisal
Hi,
I set up the JMS Server , Module Sucefully .But when i tried to run the
“java QueueReceive t3://localhost:7001″
Program , it gives me below error :-
[oracle@myweblogic ss]$ java QueueSend t3://localhost:7001
Exception in thread “Main Thread” java.lang.NoClassDefFoundError: QueueSend
Could not find the main class: QueueSend. Program will exit.
Any idea how to get rid of this error .I understand this is related to ClassPath but not sure which Class i have missed.Here is my ClassPath Setting :-
[oracle@myweblogic ss]$ echo $CLASSPATH
/u01/app/oracle/Middleware/patch_wls1032/profiles/default/sys_manifest_classpath/weblogic_patch.jar:/u01/app/oracle/Middleware/patch_oepe1032/profiles/default/sys_manifest_classpath/weblogic_patch.jar:/u01/app/oracle/Middleware/jrockit_160_14_R27.6.5-32/lib/tools.jar:/u01/app/oracle/Middleware/utils/config/10.3/config-launch.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/weblogic_sp.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/weblogic.jar:/u01/app/oracle/Middleware/modules/features/weblogic.server.modules_10.3.2.0.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/webservices.jar:/u01/app/oracle/Middleware/modules/org.apache.ant_1.7.0/lib/ant-all.jar:/u01/app/oracle/Middleware/modules/net.sf.antcontrib_1.0.0.0_1-0b2/lib/ant-contrib.jar:/u01/app/oracle/Middleware/wlserver_10.3/common/eval/pointbase/lib/pbclient57.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/xqrl.jar:/u01/app/oracle/Middleware/wlserver_10.3/common/eval/pointbase/lib/pbclient57.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/xqrl.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/wlthint3client.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/wljmsclient.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/wlclient.jar:/u01/app/oracle/Middleware/patch_wls1032/profiles/default/sys_manifest_classpath/weblogic_patch.jar:/u01/app/oracle/Middleware/patch_oepe1032/profiles/default/sys_manifest_classpath/weblogic_patch.jar:/home/oracle/jrockit-jdk1.6.0_24-R28.1.3-4.0.1/lib/tools.jar:/u01/app/oracle/Middleware/utils/config/10.3/config-launch.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/weblogic_sp.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/weblogic.jar:/u01/app/oracle/Middleware/modules/features/weblogic.server.modules_10.3.2.0.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/webservices.jar:/u01/app/oracle/Middleware/modules/org.apache.ant_1.7.0/lib/ant-all.jar:/u01/app/oracle/Middleware/modules/net.sf.antcontrib_1.0.0.0_1-0b2/lib/ant-contrib.jar:/u01/app/oracle/Middleware/wlserver_10.3/common/eval/pointbase/lib/pbclient57.jar:/u01/app/oracle/Middleware/wlserver_10.3/server/lib/xqrl.jar
Please let me know about this .Thanks in Advance .
Thanks and Regards,
Purushotham Yallanki
Hi Purushotham,
Have you compiled the QueueSend class and kept in directory where you are running the program?
Thanks,
Faisal
What is the performance of Distributed Queue on weblogic, when it is deployed over 4 managed server and only 1 server is up ?
will there be any drop of messages ?
Hi Rahul,
There should not be any drop of message. But if you want to keep only one server up why will you use a distributed queue?
-Faisal
iam new to weblogic I did course on weblogic 11g but I don’t clear idea on weblogic .please guide me how to get all information on weblogic in detail.
that was awesome
thanks Sabarish