Haitham Safi
2013-04-01 11:39:47 UTC
Haitham Safi [https://community.jboss.org/people/haithamnor] created the discussion
"JNDI Remote Queue over web service"
To view the discussion, visit: https://community.jboss.org/message/805801#805801
--------------------------------------------------------------
Hi everybody,,,
iI create a web service to send a message, for local queue on local PC (127.0.0.1) it is correcte but for remote queue (192.168.20.35) as same queue name on remote PC return *< D queue not bound>* *Error* :
i used jboss 4.2.3 + axis2 + with eclipse
Same configuration for queue and username,password on local and remote machines.
------------------------------------------------------------------------
package edu;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
public class MessageWS
{
String body = "";
 Â
public String Send_Messages(String msg) throws ServletException, IOException, URISyntaxException {
try
   {
Â
    Context init =MessageWS.getInitialContext();
    javax.jms.Queue destination =       (javax.jms.Queue) init.lookup("queue/D");
         ConnectionFactory connectionFactory =  (ConnectionFactory) init.lookup("ConnectionFactory");
         Connection connection = connectionFactory.createConnection("jone","pas123");//
         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageProducer producer = session.createProducer(destination);
         Date date =new Date();
        Â
         TextMessage message = session.createTextMessage();
         message.setText(msg);
      Â
         connection.start();
      Â
         producer.send(message);
         body = message.getText();
       Â
        Â
         session.close();
         connection.close();
     }
   catch (Exception e)
     {
         return(e.toString());
     }
return body   ;
}
public static Context getInitialContext () throws JMSException,NamingException
{
 Properties prop = new Properties();
    prop.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
 prop.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
 prop.setProperty("java.naming.provider.url", "192.168.20.35:1099);
 Context context = new InitialContext(prop);
Â
 return context;
}
}
    i execute the code in side JAVA Application it was workini correct, but Through web service i got an error
So any idea or help? :(
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/805801#805801]
Start a new discussion in JNDI and Naming at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2083]
"JNDI Remote Queue over web service"
To view the discussion, visit: https://community.jboss.org/message/805801#805801
--------------------------------------------------------------
Hi everybody,,,
iI create a web service to send a message, for local queue on local PC (127.0.0.1) it is correcte but for remote queue (192.168.20.35) as same queue name on remote PC return *< D queue not bound>* *Error* :
i used jboss 4.2.3 + axis2 + with eclipse
Same configuration for queue and username,password on local and remote machines.
------------------------------------------------------------------------
package edu;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
public class MessageWS
{
String body = "";
 Â
public String Send_Messages(String msg) throws ServletException, IOException, URISyntaxException {
try
   {
Â
    Context init =MessageWS.getInitialContext();
    javax.jms.Queue destination =       (javax.jms.Queue) init.lookup("queue/D");
         ConnectionFactory connectionFactory =  (ConnectionFactory) init.lookup("ConnectionFactory");
         Connection connection = connectionFactory.createConnection("jone","pas123");//
         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageProducer producer = session.createProducer(destination);
         Date date =new Date();
        Â
         TextMessage message = session.createTextMessage();
         message.setText(msg);
      Â
         connection.start();
      Â
         producer.send(message);
         body = message.getText();
       Â
        Â
         session.close();
         connection.close();
     }
   catch (Exception e)
     {
         return(e.toString());
     }
return body   ;
}
public static Context getInitialContext () throws JMSException,NamingException
{
 Properties prop = new Properties();
    prop.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
 prop.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
 prop.setProperty("java.naming.provider.url", "192.168.20.35:1099);
 Context context = new InitialContext(prop);
Â
 return context;
}
}
    i execute the code in side JAVA Application it was workini correct, but Through web service i got an error
So any idea or help? :(
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/805801#805801]
Start a new discussion in JNDI and Naming at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2083]