3 Replies Latest reply on Mar 14, 2004 11:24 PM by Adrian Brock

    Problem while sending messages to Queue/B

    mlsreekanth Newbie

      Hi all,

      I have deployed a workflow engine into JBOSS with jetty. This Workflow engine uses the default queues like Queue/A, Queue/B...etc.
      Now, i want to send messages to the queues where MDBs are listening to these queues which may invoke Workflow engine. When, i send messages to these queues in LAN, it is working fine,

      When, i send messages through the internet it was giving connection refused error.
      JBOSS is running WIN2K Server.
      It was behind a NAT router and router is using firewall. We configured the ports 8080,1099, 8090-8093 in the router.

      When i triewd to access the workflow engine from outside with external ip, like http://ext_ip:8080/workflow/
      it is working fine.

      Now, i am sending messages using the following code,

      /*
      * MsgSender.java
      *
      * Created on February 23, 2004, 5:46 PM
      */

      /**
      *
      * @author Administrator
      */

      import javax.jms.*;
      import javax.naming.*;
      import org.apache.log4j.*;
      import java.util.*;

      public class MsgSender {

      private String destinationJndiName = "queue/B";
      private String connectionFactoryJndiName = "UILConnectionFactory";
      private String urlPkgPrefixes = "org.jboss.naming:org.jnp.interfaces";

      /** Creates a new instance of MsgSender */
      public MsgSender() {
      }

      public static void main(String args[]) {

      MsgSender msgSender = new MsgSender();
      msgSender.sendMessage(null);
      }

      public void sendMessage(HashMap msg){
      QueueConnection queueConnection = null;
      QueueSession queueSession = null;
      QueueSender queueSender = null;


      try {

      try {

      Context jndiContext = null;
      // jndiContext = new InitialContext();
      //JNDIParm.put(Context.URL_PKG_PREFIXES, urlPkgPrefixes );
      java.util.Hashtable JNDIParm = new java.util.Hashtable();
      JNDIParm.put(Context.PROVIDER_URL, "jnp://ext_ip:1099/");
      JNDIParm.put(Context.URL_PKG_PREFIXES, urlPkgPrefixes );
      JNDIParm.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");


      jndiContext = new InitialContext(JNDIParm);

      System.out.println(jndiContext+"JNDI Properties "+jndiContext.getEnvironment()+" Provider URL is "+jndiContext.PROVIDER_URL);
      //destinationJndiName = getDestinationJndiName(destinationJndiName);
      // InitialContext jndiContext = new InitialContext();
      System.out.println("Jndi context name "+jndiContext.getNameInNamespace());
      QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup(connectionFactoryJndiName);
      queueConnection = queueConnectionFactory.createQueueConnection();
      queueSession = queueConnection.createQueueSession( false, Session.AUTO_ACKNOWLEDGE );
      System.out.println("After creatinbg the queue session");
      Queue queue = (Queue) jndiContext.lookup(destinationJndiName);
      queueSender = queueSession.createSender(queue);
      queueConnection.start();

      ObjectMessage message;
      // TextMessage textMessage = queueSession.createTextMessage();
      //textMessage.setText("Hello world" );
      message = queueSession.createObjectMessage();

      message.setObject(msg);

      //log.debug( "sending the message... ");
      queueSender.send(message);
      //log.debug( "message sent. ");
      System.out.println( message.getJMSMessageID());

      //interactionContext.log( "message '" + textMessage.getJMSMessageID() + "' was sent to queue '" + destinationJndiName + "'" );

      } finally {
      if ( queueSender != null ) queueSender.close();
      if ( queueSession != null ) queueSession.close();
      if ( queueConnection != null ) queueConnection.close();
      }

      } catch (Exception e) {
      e.printStackTrace();
      //e.prerror("error in performing jms tasks :", e);
      }


      }
      }


      But, it is giving the following error stating that the internal ip is not responding.

      this is the actual stack trace

      javax.naming.CommunicationException [Root exception is java.rmi.ConnectException: Connection refused to host: 192.168.123.2;

      nested exception is:
      java.net.ConnectException: Connection timed out: connect]
      at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:611)
      at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:471)
      at javax.naming.InitialContext.lookup(InitialContext.java:347)
      at MsgSender.sendMessage(MsgSender.java:78)
      at InternationalCaseSend$CaseSenderThread.run(InternationalCaseSend.java:301)
      Caused by: java.rmi.ConnectException: Connection refused to host: 192.168.123.2; nested exception is:
      java.net.ConnectException: Connection timed out: connect
      at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:567)
      at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:185)
      at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:171)
      at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:101)
      at org.jnp.server.NamingServer_Stub.lookup(Unknown Source)
      at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:492)
      ... 4 more
      Caused by: java.net.ConnectException: Connection timed out: connect
      at java.net.PlainSocketImpl.socketConnect(Native Method)
      at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:305)
      at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:171)
      at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:158)
      at java.net.Socket.connect(Socket.java:452)
      at java.net.Socket.connect(Socket.java:402)
      at java.net.Socket.(Socket.java:309)
      at java.net.Socket.(Socket.java:124)
      at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:22)
      at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:128)
      at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:562)
      ... 9 more


      Kindly, help me in this regard.

      Thanks in advance.

      Srikanth