configurer Jboss pour JMS

configurer Jboss pour JMS - Java - Programmation

Marsh Posté le 11-08-2005 à 10:37:20    

salut !
je voudrais pouvoir utiliser Jms sur Jboss, mais voila, mon prog me renvoit l'erreur suivante:
 
Starting...
javax.naming.CommunicationException [Root exception is java.rmi.RemoteException: Service unavailable.]
 at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:707)
 at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:572)
 at javax.naming.InitialContext.lookup(Unknown Source)
 at com.xml.sax.Sender.main(Sender.java:24)
Caused by: java.rmi.RemoteException: Service unavailable.
 at org.jboss.ha.framework.interfaces.HARMIClient.invokeRemote(HARMIClient.java:158)
 at org.jboss.ha.framework.interfaces.HARMIClient.invoke(HARMIClient.java:196)
 at $Proxy0.lookup(Unknown Source)
 at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:610)
 ... 3 more
Ending...
 
je débute avec Jboss, avec eclipse aussi, enfin bref, avec J2EE.
j'ai lu un article sur la configuration de Jboss mais, je desespère de trouver comment configuré le serveur !
 
que signifit "javax.naming.CommunicationException [Root exception is java.rmi.RemoteException: Service unavailable"??
que parametre dois je modifier ?
 

Code :
  1. public class Sender {
  2.     public static void main(String[] args) {
  3.         System.out.println("Starting..." );
  5.         QueueConnectionFactory aQCF = null;
  6.         QueueConnection aQC = null;
  7.         QueueSession aQS = null;
  8.         QueueSender aSender  = null;
  9.         try {
  10.             InitialContext aIC = new InitialContext(Resource.getResources());
  11.             aQCF = (QueueConnectionFactory) aIC.lookup("ConnectionFactory" );
  12.             aQC = aQCF.createQueueConnection();
  13.             aQS = aQC.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  14.             Queue aQueue = (Queue) aIC.lookup("queue/A" );
  15.                    //ici, une queue qui tourne sur jboss  
  16.             aSender = aQS.createSender(aQueue);
  17.             aQC.start();
  18.             for (int i = 0; i < 10; i++) {
  19.                 aSender.send(aQS.createObjectMessage(new Integer(i)));
  20.             }
  21.         } catch (Exception e) {
  22.             e.printStackTrace();
  23.         } finally {
  24.             try {
  25.                 if (aSender != null) {
  26.                     aSender.close();
  27.                 }
  28.                 if (aQS != null) {
  29.                     aQS.close();
  30.                 }
  31.                 if (aQC != null) {
  32.                     aQC.stop();
  33.                     aQC.close();
  34.                 }
  35.             } catch (JMSException e) {
  36.                 e.printStackTrace();
  37.             }
  38.         }
  40.         System.out.println("Ending..." );
  41.     }
  42. }


 
 

Code :
  1. package com.xml.sax;
  3. import java.io.InputStreamReader;
  5. import javax.jms.JMSException;
  6. import javax.jms.MessageListener;
  7. import javax.jms.ObjectMessage;
  8. import javax.jms.QueueConnection;
  9. import javax.jms.QueueConnectionFactory;
  10. import javax.jms.QueueReceiver;
  11. import javax.jms.QueueSession;
  12. import javax.naming.InitialContext;
  14. import sun.misc.Queue;
  16. import com.sun.corba.se.internal.iiop.messages.Message;
  18. public abstract class Receiver {
  19.     protected void doAll() {
  20.         QueueConnectionFactory aQCF = null;
  21.         QueueConnection aQC = null;
  22.         QueueSession aQS = null;
  23.         QueueReceiver aQR  = null;
  24.         try {
  25.             InitialContext aIC = new InitialContext(Resource.getResources());
  26.             aQCF = (QueueConnectionFactory) aIC.lookup("ConnectionFactory" );
  27.             aQC = aQCF.createQueueConnection();
  28.             aQS = createQueueSession(aQC);
  29.             final QueueSession aQS1 = aQS;
  30.             Queue aQueue = (Queue) aIC.lookup("queue/A" );
  31.             aQR = aQS.createReceiver(aQueue);
  32.             MessageListener aML = new MessageListener() {
  33.                 public void onMessage(Message aMessage) {
  34.                     try {
  35.                         processMessage(aMessage, aQS1);
  36.                     } catch (JMSException e) {
  37.                         e.printStackTrace();
  38.                     }
  39.                 }
  40.             };
  41.            
  42.             aQR.setMessageListener(aML);
  43.             aQC.start();
  44.             InputStreamReader aISR = new InputStreamReader(System.in);
  45.             char aAnswer = ' ';
  46.             do {
  47.                 aAnswer = (char) aISR.read();
  48.                 if ((aAnswer == 'r') || (aAnswer == 'R')) {
  49.                     aQS.recover();
  50.                 }
  51.             } while ((aAnswer != 'q') && (aAnswer != 'Q'));
  52.         } catch (Exception e) {
  53.             e.printStackTrace();
  54.         } finally {
  55.             try {
  56.                 if (aQR != null) {
  57.                     aQR.close();
  58.                 }
  59.                 if (aQS != null) {
  60.                     aQS.close();
  61.                 }
  62.                 if (aQC != null) {
  63.                     aQC.stop();
  64.                     aQC.close();
  65.                 }
  66.             } catch (JMSException e) {
  67.                 e.printStackTrace();
  68.             }
  69.         }
  70.     }
  72.     protected void processMessage(Message aMessage, QueueSession aQS) throws JMSException {
  73.         if (aMessage instanceof ObjectMessage) {
  74.             ObjectMessage aOM = (ObjectMessage) aMessage;
  75.             System.out.print(aOM.getObject() + " " );
  76.             System.out.print(" message recieved " );
  77.         }
  78.     }
  80.     protected abstract QueueSession createQueueSession(
  81.         QueueConnection aQC
  82.     ) throws JMSException;
  83. }

Reply

Marsh Posté le 11-08-2005 à 10:37:20   

Reply

Marsh Posté le 11-08-2005 à 17:07:09    

et bien voila, ca marche !
 
pour ceux qui cherchent encore une solution a leur problemes de jms :
 
http://wiki.jboss.org/wiki/attach? [...] lution.txt
 
et je partage l'avis du mec, y'a aucun tutoriel "clair" pour les débutant sur le net !!!
 
merci a lui !

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed