While connecting with JMS through an Applet, the following error is taking place. But when we connected through JAVA application its working fine. The code is attached.
javax.naming.NamingException: Couldn't connect to any host. Root exception is org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code: 203 completed: No at com.sun.corba.se.internal.iiop.IIOPConnection.writeLock(IIOPConnection.java:562)
at com.sun.corba.se.internal.iiop.BufferManagerWriteGrow.sendMessage(BufferManagerWriteGrow.java:55)
at com.sun.corba.se.internal.iiop.IIOPOutputStream.finishSendingMessage(IIOPOutputStream.java:159)
at com.sun.corba.se.internal.iiop.IIOPOutputStream.invoke(IIOPOutputStream.java:117)
at com.sun.corba.se.internal.iiop.ClientRequestImpl.invoke(ClientRequestImpl.java:76)
at com.sun.corba.se.internal.corba.ClientDelegate.invoke(ClientDelegate.java:229)
at com.sun.corba.se.internal.corba.ClientDelegate.invoke(ClientDelegate.java:271)
at com.sun.corba.se.internal.corba.InitialNamingClient.resolve(InitialNamingClient.java:1016)
at com.sun.corba.se.internal.corba.InitialNamingClient.resolveUsingBootstrapProtocol(InitialNamingClient.java:687)
at com.sun.corba.se.internal.corba.InitialNamingClient.cachedInitialReferences(InitialNamingClient.java:1085)
at com.sun.corba.se.internal.corba.InitialNamingClient.resolve_initial_references(InitialNamingClient.java:978)
at com.sun.corba.se.internal.corba.ORB.resolve_initial_references(ORB.java:2422)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReferenceWithRetry(ORBHelper.java:476)
at weblogic.corba.j2ee.naming.ORBHelper.getORBReference(ORBHelper.java:455)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContext(InitialContextFactoryImpl.java:97)
at weblogic.corba.j2ee.naming.InitialContextFactoryImpl.getInitialContext(InitialContextFactoryImpl.java:42)
at weblogic.jndi.WLInitialContextFactory.getInitialContext(WLInitialContextFactory.java:41)
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:662)
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:243)
at javax.naming.InitialContext.init(InitialContext.java:219)
at javax.naming.InitialContext.<init>(InitialContext.java:195)
at AsyncTopicReceiver.initialise(AsyncTopicReceiver.java:35)
at AsyncTopicReceiver.main(AsyncTopicReceiver.java:112)
Caught an unexpected exceptionjavax.naming.NamingException: Couldn't connect to any host [Root exception is org.omg.CORBA.COMM_FAILURE: vmcid: SUN minor code : 203 completed: No]
The Code:
AppletEx.java
--------------
import java.awt.*;
import java.awt.event.*;
import java.applet.*;
import java.net.*;
import javax.swing.JTable;
import javax.swing.JScrollPane;
/*
<APPLET code="AppletEx.class" WIDTH="200" HEIGHT="300" >
</APPLET>
*/
public class AppletEx extends Applet {
public void init()
{
}
public void start()
{
AsyncTopicReceiver asyncTopicReceiver = new AsyncTopicReceiver();
System.out.println("AsyncTopicReceiver Started");
asyncTopicReceiver.startEx();
System.out.println("AsyncTopicReceiver Ends");
}
}
------------------------
AsyncTopicReceiver.java
------------------------
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.jms.*;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.MessageListener;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.jms.Topic;
import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.ObjectMessage;
import javax.jms.JMSException;
import java.util.Properties;
public class AsyncTopicReceiver implements MessageListener
{
TopicConnectionFactory topicConnectionFactory;
TopicConnection topicConnection;
TopicSession topicSession;
TopicSubscriber topicSubscriber;
Topic topic;
boolean finished = false;
String msg;
public void initialise(){
try{
System.out.println("Starting Main");
Properties h = new Properties();
h.put(Context.INITIAL_CONTEXT_FACTORY,
"weblogic.jndi.WLInitialContextFactory");
h.put(Context.PROVIDER_URL, "t3://localhost:7001");
Context initial = new InitialContext(h);
topicConnectionFactory = (TopicConnectionFactory)initial.lookup("TestJMSConnectionFactory");
topicConnection = topicConnectionFactory.createTopicConnection();
topicSession = topicConnection.createTopicSession(false,javax.jms.TopicSession.AUTO_ACKNOWLEDGE);
topic = (Topic)initial.lookup("TestJMSTopic");
topicSubscriber = topicSession.createSubscriber(topic);
topicSubscriber.setMessageListener(this);
topicConnection.start();
}
catch (Exception e){
e.printStackTrace();
System.out.println("Caught an unexpected exception" + e);
}
}
public void onMessage(Message message){
System.out.println("This is onMessage method");
try{
if(message instanceof TextMessage){
TextMessage txtMsg = (TextMessage) message;
System.out.println("Message received : " + txtMsg.getText());
System.in.read();
}
if(message instanceof ObjectMessage){
ObjectMessage objMsg = (ObjectMessage) message;
System.out.println("Message received : " + objMsg.getObject());
msg= objMsg.getObject().toString();
System.in.read();
}
}
catch (Exception e){
e.printStackTrace();
System.out.println("Exception in onMessage" + e);
}
}
public void close() throws JMSException{
try{
topicSubscriber.close();
topicSession.close();
topicConnection.close();
}
catch(Exception e){
System.out.println("Exception " + e);
}
}
public void startEx(){
try{
AsyncTopicReceiver test = new AsyncTopicReceiver();
test.initialise();
System.out.println("ready to receive messages");
synchronized(test){
while (!test.finished){
try{
test.wait();
}
catch(InterruptedException ex){
}
}
test.close();
}
}
catch(JMSException ex){
System.out.println("JMSException : " + ex);
}
}
public static void main(String[] args){
try{
AsyncTopicReceiver test = new AsyncTopicReceiver();
test.initialise();
System.out.println("ready to receive messages");
synchronized(test){
while (!test.finished){
try{
test.wait();
}
catch(InterruptedException ex){
}
}
test.close();
}
}
catch(JMSException ex){
System.out.println("JMSException : " + ex);
}
}
/**
* @return
*/
public String getMsg() {
return msg;
}
/**
* @param string
*/
public void setMsg(String string) {
msg = string;
}
}
