jboss-user
[Arriba] [Todas las Listas]

[jboss-Usuario] [JBoss Messaging] - JMS - mensaje duplicado en Jboss 4.1

To: User development <jboss-user@xxxxxxxxxxxxxxx>
Subject: [jboss-Usuario] [JBoss Messaging] - JMS - mensaje duplicado en Jboss 4.1, pero trabajando bien en Weblogic 6
From: Vijay DR <do-not-reply@xxxxxxxxx>
Date: Mon, 12 Sep 2011 09:04:43 -0400
Auto-submitted: yes
Delivery-date: Mon, 12 Sep 2011 09:05:50 -0400
Envelope-to: traductor@xxxxxxxxxxx
List-archive: <http://lists.jboss.org/pipermail/jboss-user>
List-help: <mailto:jboss-user-request@lists.jboss.org?subject=help>
List-id: The JBoss User main mailing list <jboss-user.lists.jboss.org>
List-post: <mailto:jboss-user@lists.jboss.org>
List-subscribe: <https://lists.jboss.org/mailman/listinfo/jboss-user>, <mailto:jboss-user-request@lists.jboss.org?subject=subscribe>
List-unsubscribe: <https://lists.jboss.org/mailman/listinfo/jboss-user>, <mailto:jboss-user-request@lists.jboss.org?subject=unsubscribe>
Reply-to: The JBoss User main mailing list <jboss-user@xxxxxxxxxxxxxxx>
Sender: jboss-user-bounces@xxxxxxxxxxxxxxx
*Vijay DR. [*http://comunidad.*jboss.*org/Personas/*drvijayy2*k2] creó la discusión

"*JMS - mensaje duplicado en *Jboss 4.1, pero trabajando bien en *Weblogic 6"

para ver la discusión, visita: *http://comunidad.*jboss.*org/Mensaje/626028#626028

--------------------------------------------------------------
tenemos una aplicación que creó en 
 *weblogic 6 
 *jdk1.3 
 
 *ahora emigramos igual a *jboss (*http://www.coderanch.com/foros/*f-63/*JBoss) 4.1 con *jdk1.6 
 
 Asuntos 
*  
 
 1. El Rendimiento es muy despacio 
 2. El Mensaje duplicado que llama [llama repetidamente, así que la producción es como duplicado] 
 
 
 aquí es nuestro **weblogic 6 *jms poniendo* 
 
 
llanura de vista (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)copia a *clipboard (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)impresión (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)? (*http://Www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)
1. <*JMSConnectionFactory *AllowCloseInOnMessage="Falso"  
2.         *DefaultDeliveryMode="Persistente" *DefaultPriority="4"  
3.         *DefaultTimeToLive="0"  
4.         *JNDIName="*com.Consulta.*QueryConnectionFactory"  
5.         *MessagesMaximum="-1" Consulta="de Nombre Fábrica de Conexión"  
6.         *OverrunPolicy="*KeepOld" Objetivos="*myserver" *TransactionTimeout="900"/>  

 
 
 
 **Java código  [*queue nombre creamos como *mbean] y ningún problema en el código trabaja.* 
 
  
Llanura de vista (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)copia a *clipboard (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)impresión (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)? (*http://Www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)
1. Privado final *static Cadena *JMS_FÁBRICA="*com.Consulta.*QueryConnectionFactory";  
2. Privado final *static Cadena *QUEUE_NOMBRE="*com.*QueryQueue";  
3. 
4. Privado *static Contexto *ctx;  
5. 
6. // *todo:    
7. // Puede la conexión y otras variables ser *lazily creado y almacenado  
8. // Variables tan privadas en vez de cada tiempo?  
9. Final pública *static *void *dispatchQuery(Cadena *sessionDirectory,  
10. Final *QueryInfo *queryInfo)   
11. Echa *ControllerException  
#num{^12. Prueba  
13.  
#Num{^14. 
15.             *ctx = *getInitialContext();  
16. 
17.             *QueueConnectionFactory *cf = (*QueueConnectionFactory) *ctx.*lookup(*JMS_FÁBRICA);  
18. 
19.             *QueueConnection *queueConnection = *cf.*createQueueConnection();  
20.             *queueConnection.Inicio();  
21. 
22.             *QueueSession Sesión = *queueConnection.*createQueueSession(Falso,   // no-tramitado  
23.                                                          Sesión.El COCHE_RECONOCE);  
24. 
25.             *log("La Sesión es: " + sesión);  
26. 
27.             *Queue *queue = *null;  
28. 
29. Prueba  
30.  
#Num{^31.                 *queue = (*Queue) *ctx.*lookup(*QUEUE_NOMBRE);  
32.             } Coge (*NamingException *ne)  
#num{^33. Prueba  
34.  
#Num{^35.                     *queue = Sesión.*createQueue(*QUEUE_NOMBRE);  
36.                     *ctx.Liga(*QUEUE_NOMBRE, *queue);  
37.                 } Coge (Excepción *e)  
#num{^38.                     *e.*printStackTrace();  
39.                 }  
40.             }  
41. 
42.             *log("*Queue Es: " + *queue);  
43. 
44.             *QueueSender *sender = Sesión.*createSender(*queue);  
45. 
46.             *QueryMessage *queryMessage = Nuevo *QueryMessage(*sessionDirectory, *queryInfo);  
47.             *ObjectMessage *om = Sesión.*createObjectMessage(*queryMessage);  
48.             *log("<<< *DISPATCHER.. >> Antes de Enviar mensaje de + " *om);  
49.             *sender.Envía(*om);  
50.             *log("Mensaje enviado.");    
51.         } Coge (*JMSException *je)  
#num{^52.             Mensaje de cadena = "no Podría enviar el mensaje debido a:\*n" +  
53.                              *je.*getMessage();  
54. Echa nuevo *ControllerException(mensaje);  
55.         } Coge (*NamingException *ne)  
#num{^56. Echa nuevo *ControllerException(*ne.*getMessage());  
57.         }  
58.   }  

 
 
 
 *JBoss 4.1, el mismo código no trabajando perfectamente. 
 
 **jbossmq-Destinos-servicio.*xml* 
 
 
Llanura de vista (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)copia a *clipboard (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)impresión (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)? (*http://Www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)
1. <*mbean Código="*org.*jboss.*mq.*server.*jmx.*Queue"   
2.       Nombre="*jboss.*mq.Destino:servicio=*Queue,nombre=*com.Consulta.*QueryQueue">   
3.       <Depende opcional-atributo-nombre="*DestinationManager">*jboss.*mq:Servicio=*DestinationManager</depende>  
4.     </*mbean>   

 
 
 **JAVA, utilizamos UIL2*ConnectionFactory* 
 
  
llanura de vista (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)copia a *clipboard (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)impresión (*http://www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)? (*http://Www.coderanch.com/*t/552338/*JBoss/*JMS-duplicado-mensaje-*Jboss-pero#)
1.  Privado final *static Cadena *JMS_UIL="de FÁBRICA2*ConnectionFactory";   
2. Privado final *static Cadena *QUEUE_NOMBRE="*queue/*com.Consulta.*QueryQueue";  
3. 
4. // El Resto del código es mismo cuando encima. 
--------------------------------------------------------------

Respuesta a este mensaje por ir a Comunidad
[*http://comunidad.*jboss.*org/Mensaje/626028#626028]

Empieza una discusión nueva en *JBoss *Messaging en Comunidad
[*http://comunidad.*jboss.*org/Escoge-contenedor!Entrada.*jspa?*contentType=1&*containerType=14&contenedor=2042]

Vijay DR [http://community.jboss.org/people/drvijayy2k2] created the discussion

"JMS - duplicate message in Jboss 4.1, but working fine in Weblogic 6"

To view the discussion, visit: http://community.jboss.org/message/626028#626028

--------------------------------------------------------------
We have a application which created in 
 weblogic 6 
 jdk1.3 
 
 *now we migrate the same into jboss (http://www.coderanch.com/forums/f-63/JBoss) 4.1 with jdk1.6 
 
 Issues 
*  
 
 1. performance is very slow 
 2. duplicate message calling [it calls repeatedly, so output is like duplicate] 
 
 
 here is our *weblogic 6 jms setting* 
 
 
view plain (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)copy to clipboard (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)print (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)? (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)
1. <JMSConnectionFactory AllowCloseInOnMessage="false"  
2.         DefaultDeliveryMode="Persistent" DefaultPriority="4"  
3.         DefaultTimeToLive="0"  
4.         JNDIName="com.query.QueryConnectionFactory"  
5.         MessagesMaximum="-1" Name="Query Connection Factory"  
6.         OverrunPolicy="KeepOld" Targets="myserver" TransactionTimeout="900"/>  

 
 
 
 *Java code  [queue name we created like mbean] and no problem in the code it works.* 
 
  
view plain (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)copy to clipboard (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)print (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)? (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)
1. private final static String JMS_FACTORY="com.query.QueryConnectionFactory";  
2. private final static String QUEUE_NAME="com.QueryQueue";  
3. 
4. private static Context ctx;  
5. 
6. // todo:    
7. // can the connection and other variables be lazily created and stored  
8. // as private variables instead of each time?  
9. public final static void dispatchQuery(String sessionDirectory,  
10. final QueryInfo queryInfo)   
11. throws ControllerException {  
12. try  
13.         {  
14. 
15.             ctx = getInitialContext();  
16. 
17.             QueueConnectionFactory cf = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);  
18. 
19.             QueueConnection queueConnection = cf.createQueueConnection();  
20.             queueConnection.start();  
21. 
22.             QueueSession session = queueConnection.createQueueSession(false,   // non-transacted  
23.                                                          Session.AUTO_ACKNOWLEDGE);  
24. 
25.             log("Session is: " + session);  
26. 
27.             Queue queue = null;  
28. 
29. try  
30.             {  
31.                 queue = (Queue) ctx.lookup(QUEUE_NAME);  
32.             } catch (NamingException ne) {  
33. try  
34.                 {  
35.                     queue = session.createQueue(QUEUE_NAME);  
36.                     ctx.bind(QUEUE_NAME, queue);  
37.                 } catch (Exception e) {  
38.                     e.printStackTrace();  
39.                 }  
40.             }  
41. 
42.             log("Queue is: " + queue);  
43. 
44.             QueueSender sender = session.createSender(queue);  
45. 
46.             QueryMessage queryMessage = new QueryMessage(sessionDirectory, queryInfo);  
47.             ObjectMessage om = session.createObjectMessage(queryMessage);  
48.             log("<<< DISPATCHER.. >> Before Sending message of " + om);  
49.             sender.send(om);  
50.             log("Sent message.");    
51.         } catch (JMSException je) {  
52.             String message = "Could not send the message due to:\n" +  
53.                              je.getMessage();  
54. throw new ControllerException(message);  
55.         } catch (NamingException ne) {  
56. throw new ControllerException(ne.getMessage());  
57.         }  
58.   }  

 
 
 
 JBoss 4.1, the same code not working perfectly. 
 
 *jbossmq-destinations-service.xml* 
 
 
view plain (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)copy to clipboard (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)print (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)? (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)
1. <mbean code="org.jboss.mq.server.jmx.Queue"   
2.       name="jboss.mq.destination:service=Queue,name=com.query.QueryQueue">   
3.       <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>  
4.     </mbean>   

 
 
 *JAVA, we used UIL2ConnectionFactory* 
 
  
view plain (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)copy to clipboard (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)print (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)? (http://www.coderanch.com/t/552338/JBoss/JMS-duplicate-message-Jboss-but#)
1.  private final static String JMS_FACTORY="UIL2ConnectionFactory";   
2. private final static String QUEUE_NAME="queue/com.query.QueryQueue";  
3. 
4. // rest of the code is same as above. 
--------------------------------------------------------------

Reply to this message by going to Community
[http://community.jboss.org/message/626028#626028]

Start a new discussion in JBoss Messaging at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2042]

_______________________________________________
*jboss-Usuario *mailing lista
*jboss-user@xxxxxxxxxxxxxxx
*https://listas.*jboss.*org/*mailman/*listinfo/*jboss-Usuario
_______________________________________________
jboss-user mailing list
jboss-user@xxxxxxxxxxxxxxx
https://lists.jboss.org/mailman/listinfo/jboss-user
<Anterior por Tema] Tema Actual [Siguiente por Tema>
  • [jboss-Usuario] [JBoss Messaging] - JMS - mensaje duplicado en Jboss 4.1, pero trabajando bien en Weblogic 6, Vijay DR <=