0 Replies Latest reply on Oct 12, 2006 2:29 PM by sri reddy

    configuring remote topic host and port

    sri reddy Newbie

      Hi

      Im using Jboss4.0.3SP1, Im very new to JMS&MDB's. I have written a MDB and a client which subscribes the msgs. I have to connect to the remote Topic which is in Seebeyond very old version and didnt have jndi.

      The following is the code which i implemented for connecting to remote topic and ejb-jar.xml, jboss.xml

      Im unable to listen to the messages after deploying the jar file.

      import javax.jms.JMSException;
      import javax.jms.Message;
      import javax.jms.MessageListener;
      import javax.jms.Topic;
      import javax.jms.TopicConnection;
      import javax.jms.TopicConnectionFactory;
      import javax.jms.TopicPublisher;
      import javax.jms.*;
      import javax.ejb.*;


      import javax.jms.TopicSession;
      import javax.jms.TextMessage;

      import com.seebeyond.jms.client.STCTopicConnectionFactory;
      import com.seebeyond.jms.message.STCBytesMessage;
      import com.seebeyond.jms.message.STCTextMessage;
      /**
      * @ejb.bean name="MyMBD1"
      * display-name="Name for MyMBD1"
      * description="Description for MyMBD1"
      * destination-type="javax.jms.Topic"
      * acknowledge-mode="Auto-acknowledge"
      */
      public class MyMBD1 implements MessageDrivenBean, MessageListener {

      MessageDrivenContext context = null;

      String topicName = "etXMLShipmentOrder";
      TopicConnectionFactory tcf = null;
      TopicConnection topicConnection = null;
      TopicSession topicSession = null;
      Topic topic = null;
      TopicSubscriber topicSubscriber = null;
      STCBytesMessage message = null;
      InputStreamReader inputStreamReader = null;
      char answer = '\0';
      String hostName = "egludev07";
      int port = 24820;


      public MyMBD1() {
      super();
      System.out.println("Topic name is " + topicName);
      // TODO Auto-generated constructor stub
      }

      public void setMessageDrivenContext(MessageDrivenContext context)
      throws EJBException {
      this.context = context;
      System.out.println("Insdie setMessageDrivenContext ");
      }

      public void ejbRemove() throws EJBException {
      System.out.println("ejbRemove ");
      context = null;
      if (topicConnection != null) {
      try {
      System.out.println("... Closing connection ...");
      topicSession.commit();
      topicConnection.close();
      }catch(JMSException e){
      System.out.println("Inside ejbRemove catch block ");
      e.printStackTrace();
      }
      }
      }

      public void onMessage(Message message) {
      System.out.println("onMessage");
      STCTextMessage msg = null;
      //final int MAX_MESSAGE_SIZE = 60;
      try {
      if (message instanceof TextMessage) {
      msg = (STCTextMessage) message;
      System.out.println(
      "... Reading message: " + msg.getText());
      } else {
      System.out.println(
      "Message of wrong type: "
      + message.getClass().getName());
      }
      topicSession.commit();
      } catch (Exception e) {
      System.out.println(
      " JMSException in onMessage(): " + e.toString());
      } catch (Throwable te) {
      System.out.println(
      "Exception in onMessage():" + te.getMessage());
      }

      }

      /**
      * Default create method
      *
      * @throws CreateException
      */
      public void ejbCreate() {
      System.out.println("Inside ejbCreate ");

      try {
      tcf = new STCTopicConnectionFactory(hostName, port);
      topicConnection = tcf.createTopicConnection();
      topicConnection.start();
      topicSession =
      topicConnection.createTopicSession(
      true,
      Session.AUTO_ACKNOWLEDGE);
      topic = topicSession.createTopic(topicName);
      topicSubscriber = topicSession.createDurableSubscriber(topic,"EAI_TEST_DURABLE");
      } catch (Exception e){
      System.out.println("Inside ejbCreateException Block "+e.getMessage());
      e.getStackTrace();
      }


      }

      }

      ejb-jar.xml

      <?xml version="1.0" encoding="UTF-8"?>

      <!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" "http://java.sun.com/dtd/ejb-jar_2_0.dtd">

      <ejb-jar >

      <enterprise-beans>
      <message-driven>
      <ejb-name>MyMDB1</ejb-name>
      <ejb-class>com.eagle.mdb.MyMBD1</ejb-class>
      <transaction-type>Container</transaction-type>
      <acknowledge-mode>AUTO_ACKNOWLEDGE</acknowledge-mode>
      <message-driven-destination>
      <destination-type>javax.jms.Topic</destination-type>
      </message-driven-destination>

      <resource-ref>
      <res-ref-name>jms/JmsXA</res-ref-name>
      <res-type>javax.jms.TopicConnectionFactory</res-type>
      <res-auth>Container</res-auth>
      </resource-ref>

      </message-driven>
      </enterprise-beans>
      </ejb-jar>


      jboss.xml

      <?xml version="1.0" encoding="UTF-8"?>



      <enterprise-beans>
      <message-driven>
      <ejb-name>MyMDB1</ejb-name>
      <destination-jndi-name>topic/testTopic</destination-jndi-name>

      <resource-ref>
      <res-ref-name>jms/JmsXA</res-ref-name>
      <jndi-name>TopicConnectionFactory</jndi-name>
      </resource-ref>
      </message-driven>
      </enterprise-beans>




      For my senario, pls guide me. Its very urgent.

      Thanks in Advance
      Sri