JMSCorrelationID - Historial de revisiones

Admin en 18:28 26 ago 2009

2009-08-26T18:28:33Z

Leito: /* Ver también */

2008-08-17T19:07:27Z

‎Ver también

Leito: /* Identificando un mensaje de una cola */

2008-08-17T19:07:02Z

‎Identificando un mensaje de una cola

Leito en 19:06 17 ago 2008

2008-08-17T19:06:29Z

Admin: Página nueva: El JMSCorrelationID es un campo en los mensajes JMS que permite identificar un mensaje. ==Identificando un mensaje de una cola== Hasta ahora, mandabamos un mensaje a una cola, l...

2008-07-27T13:28:27Z

Página nueva: El JMSCorrelationID es un campo en los mensajes JMS que permite identificar un mensaje. ==Identificando un mensaje de una cola== Hasta ahora, mandabamos un mensaje a una cola, l...

Página nueva

El JMSCorrelationID es un campo en los mensajes [[JMS]] que permite identificar un mensaje.

==Identificando un mensaje de una cola==

Hasta ahora, mandabamos un mensaje a una cola, la cual se iba llenando, y al pedirle un mensaje tomaba el primero (como en toda cola).

Ahora necesitamos que un mensaje enviado, vaya identificado de tal forma que se lo pueda localizar.

El Mensaje cuenta con la posibilidad de setearle diferentes cosas asociadas a JMS:

setJMSCorrelationID(String correlationID)
setJMSExpiration(long expiration)
setJMSMessageID(String id)
setJMSPriority(int priority)
etc....

A primera vista parece que para identificar un mensaje lo mejor seria setearle el ''MessageID'', pero este ID aunque se lo seteamos, al hacerle el send() lo cambia y pone un numero raro. Por esto, una forma de identificar a nuestro mensaje, es seteandole el ''JMSCorrelationID'' antes de hacerle el send:
<pre>
// Creamos el mensaje
TextMessage msg = qsession.createTextMessage();
msg.setText("Gaz, quiero la tostada "+id);
msg.setJMSCorrelationID(id);

// Enviamos el mensaje
QueueSender qsender = qsession.createSender(queue);
qsender.send(msg);
</pre>

A la hora de ir a recuperar nuestro mensaje, lo unico que cambia es la forma de construir el receiver:

String selector = "JMSCorrelationID = '"+id+"'";
QueueReceiver qreceiver = qsession.createReceiver(queue, selector);
qcon.start();
TextMessage msg = (TextMessage) qreceiver.receive();

Las reglas para hacer el selector pueden ser encontradas en la API de Message

En el caso de mandar un selector null o vacio, tomara la primera posicion de la cola como si no estuviese dicho selector.

Con los selectores se pueden hacer una gran combinacion de sentencias para utilizar estas colas de diferentes formas.

==Ver también==
* [JMS]

← Revisión anterior		Revisión del 18:28 26 ago 2009
Línea 1:		Línea 1:
		+	[[Category:JMS]]
	El JMSCorrelationID es un campo en los mensajes [[JMS]] que permite identificar un mensaje.		El JMSCorrelationID es un campo en los mensajes [[JMS]] que permite identificar un mensaje.

← Revisión anterior		Revisión del 19:07 17 ago 2008
Línea 44:		Línea 44:

	==Ver también==		==Ver también==
−	* [JMS]	+	* [[JMS]]

@@ Línea 21: / Línea 21: @@
      // Creamos el mensaje
      TextMessage msg = qsession.createTextMessage();
-     msg.setText("Gaz, quiero la tostada "+id);
+     msg.setText("Gaz, quiero la tostada " + id);
      msg.setJMSCorrelationID(id);
@@ Línea 31: / Línea 31: @@
 A la hora de ir a recuperar nuestro mensaje, lo unico que cambia es la forma de construir el receiver:
 <code java>
-     String selector = "JMSCorrelationID = '"+id+"'";
+     String selector = "JMSCorrelationID = '" + id + "'";
      QueueReceiver qreceiver = qsession.createReceiver(queue, selector);
      qcon.start();

@@ Línea 9: / Línea 9: @@
 El Mensaje cuenta con la posibilidad de setearle diferentes cosas asociadas a JMS:
   setJMSCorrelationID(String correlationID)
   setJMSExpiration(long expiration)
@@ Línea 14: / Línea 15: @@
   setJMSPriority(int priority)
   etc....
 A primera vista parece que para identificar un mensaje lo mejor seria setearle el ''MessageID'', pero este ID aunque se lo seteamos, al hacerle el send() lo cambia y pone un numero raro. Por esto, una forma de identificar a nuestro mensaje, es seteandole el ''JMSCorrelationID'' antes de hacerle el send:
-<pre>
+<code java>
      // Creamos el mensaje
      TextMessage msg = qsession.createTextMessage();
@@ Línea 25: / Línea 27: @@
      QueueSender qsender = qsession.createSender(queue);
      qsender.send(msg);
-</pre>
+</code>
 A la hora de ir a recuperar nuestro mensaje, lo unico que cambia es la forma de construir el receiver:
+<code java>
      String selector = "JMSCorrelationID = '"+id+"'";
      QueueReceiver qreceiver = qsession.createReceiver(queue, selector);
      qcon.start();
      TextMessage msg = (TextMessage) qreceiver.receive();
 Las reglas para hacer el selector pueden ser encontradas en la API de Message