JMS message récepteur de filtrage par JMSCorrelationID

Comment instancier une file d'attente JMS auditeur en java (JRE /JDK /J2EE 1.4) qui reçoit uniquement les messages qui correspondent à un JMSCorrelationID? Les messages que je suis à la recherche de ramasser ont été publiés à une file d'attente et pas un sujet, mais cela peut changer si nécessaire.

Voici le code que j'utilise actuellement pour mettre le message dans la file d'attente:

/**
* publishResponseToQueue publishes Requests to the Queue.
*
* @param   jmsQueueFactory             -Name of the queue-connection-factory
* @param   jmsQueue                    -The queue name for the request
* @param   response                     -A response object that needs to be published
* 
* @throws  ServiceLocatorException     -An exception if a request message
*                                      could not be published to the Topic
*/
private void publishResponseToQueue( String jmsQueueFactory,
String jmsQueue,
Response response )
throws ServiceLocatorException {
if ( logger.isInfoEnabled() ) {
logger.info( "Begin publishRequestToQueue: " +
jmsQueueFactory + "," + jmsQueue + "," + response );
}
logger.assertLog( jmsQueue != null && !jmsQueue.equals(""),
"jmsQueue cannot be null" );
logger.assertLog( jmsQueueFactory != null && !jmsQueueFactory.equals(""),
"jmsQueueFactory cannot be null" );
logger.assertLog( response != null, "Request cannot be null" );
try {
Queue queue = (Queue)_context.lookup( jmsQueue );
QueueConnectionFactory factory = (QueueConnectionFactory)
_context.lookup( jmsQueueFactory );
QueueConnection connection = factory.createQueueConnection();
connection.start();
QueueSession session = connection.createQueueSession( false,
QueueSession.AUTO_ACKNOWLEDGE );
ObjectMessage objectMessage = session.createObjectMessage();
objectMessage.setJMSCorrelationID(response.getID());
objectMessage.setObject( response );
session.createSender( queue ).send( objectMessage );
session.close();
connection.close();
} catch ( Exception e ) {
//XC3.2  Added/Modified BEGIN
logger.error( "ServiceLocator.publishResponseToQueue - Could not publish the " +
"Response to the Queue - " + e.getMessage() );
throw new ServiceLocatorException( "ServiceLocator.publishResponseToQueue " +
"- Could not publish the " +
"Response to the Queue - " + e.getMessage() );
//XC3.2  Added/Modified END
}
if ( logger.isInfoEnabled() ) {
logger.info( "End publishResponseToQueue: " +
jmsQueueFactory + "," + jmsQueue + response );
}
}  //end of publishResponseToQueue method

OriginalL'auteur Tom S | 2008-09-29

10

La file d'attente de la configuration de la connexion est la même, mais une fois que vous avez la QueueSession, vous réglez le sélecteur lors de la création d'un récepteur.
```
    QueueReceiver receiver = session.createReceiver(myQueue, "JMSCorrelationID='theid'");
```
puis
```
receiver.receive()
```
ou
```
receiver.setListener(myListener);
```
J'ai été lire sur le même sujet récemment et avez une question comme suit: le récepteur de toujours recevoir les messages qui ne contiennent pas le nécessaire id de corrélation et silencieusement les déposer w/o traitement, ou le fournisseur JMS lui-même de ne pas délivrer de tels messages pour le récepteur, de sorte qu'ils restent dans la file d'attente? Je sens la dernière est la bonne approche, mais à vérifier. Merci.
vous êtes correct.
Dans ce cas, la condition de filtre est "JMSCorrelationID='theid'" . J'ai besoin d'ajouter un plus de l'état comme "JMSCorrelationID='theid", "Location=ASIE". Quelle est la syntaxe pour cette condition de filtre

OriginalL'auteur Robin
5

BTW, si ce n'est pas la question qui vous a demandé si vous essayez de mettre en œuvre des réponses aux demandes de plus JMS je le recommande la lecture de cet article comme JMS API est un peu plus complexe que ce que vous pourriez imaginer et de faire de cette efficacité est d'autant plus difficile qu'il n'y paraît.

En particulier pour utiliser efficacement JMS vous devriez essayer d'éviter de créer pour les consommateurs, un seul message etc.

Aussi parce que les JMS API est donc très complexe à utiliser correctement et efficacement, en particulier avec la mise en commun, les transactions et le traitement simultané - je recommande les gens masquer le middleware de leur code de l'application, notamment via l'aide de Apache Camel Spring Remoting mise en œuvre de JMS

J'aurais économisé beaucoup de réinventer la roue, si je l'avais su à propos de Chameau, il y a quelques années.

OriginalL'auteur James Strachan

Espère que cela aidera. J'ai utilisé Ouvrir MQ.

package com.MQueues;
import java.util.UUID;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.sun.messaging.BasicQueue;
import com.sun.messaging.QueueConnectionFactory;
public class HelloProducerConsumer {
public static String queueName = "queue0";
public static String correlationId;
public static String getCorrelationId() {
return correlationId;
}
public static void setCorrelationId(String correlationId) {
HelloProducerConsumer.correlationId = correlationId;
}
public static String getQueueName() {
return queueName;
}
public static void sendMessage(String threadName) {
correlationId = UUID.randomUUID().toString();
try {
//Start connection
QueueConnectionFactory cf = new QueueConnectionFactory();
QueueConnection connection = cf.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
BasicQueue destination = (BasicQueue) session.createQueue(threadName);
MessageProducer producer = session.createProducer(destination);
connection.start();
//create message to send
TextMessage message = session.createTextMessage();
message.setJMSCorrelationID(correlationId);
message.setText(threadName + "(" + System.currentTimeMillis() 
+ ") " + correlationId +" from Producer");
System.out.println(correlationId +" Send from Producer");
producer.send(message);
//close everything
producer.close();
session.close();
connection.close();
} catch (JMSException ex) {
System.out.println("Error = " + ex.getMessage());
}
}
public static void receivemessage(final String correlationId) {
try {
QueueConnectionFactory cf = new QueueConnectionFactory();
QueueConnection connection = cf.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
BasicQueue destination = (BasicQueue) session.createQueue(getQueueName());
connection.start();
System.out.println("\n");
System.out.println("Start listen " + getQueueName() + " " + correlationId +" Queue from receivemessage");
long now = System.currentTimeMillis();
//receive our message
String filter = "JMSCorrelationID = '" + correlationId  + "'";
QueueReceiver receiver = session.createReceiver(destination, filter);
TextMessage m = (TextMessage) receiver.receive();
System.out.println("Received message = " + m.getText() + " timestamp=" + m.getJMSTimestamp());
System.out.println("End listen " + getQueueName() + " " + correlationId +" Queue from receivemessage");
session.close();
connection.close();
} catch (JMSException ex) {
System.out.println("Error = " + ex.getMessage());
}
}
public static void main(String args[]) {
HelloProducerConsumer.sendMessage(getQueueName());
String correlationId1 = getCorrelationId();
HelloProducerConsumer.sendMessage(getQueueName());
String correlationId2 = getCorrelationId();
HelloProducerConsumer.sendMessage(getQueueName());
String correlationId3 = getCorrelationId();
HelloProducerConsumer.receivemessage(correlationId2);
HelloProducerConsumer.receivemessage(correlationId1);
HelloProducerConsumer.receivemessage(correlationId3);
}
}

OriginalL'auteur saptarshi

0
```
String filter = "JMSCorrelationID = '" + msg.getJMSMessageID() + "'";
QueueReceiver receiver = session.createReceiver(queue, filter);
```
Ici le récepteur obtenir les messages pour lesquels JMSCorrelationID est égal à MessageID. ceci est très utile dans de requête/réponse paradigme.

ou vous pouvez directement mettre toute valeur:
```
QueueReceiver receiver = session.createReceiver(queue,  "JMSCorrelationID ='"+id+"'";);
```
Que vous pouvez le faire soit receiver.receive(2000); ou receiver.setMessageListener(this);

OriginalL'auteur Trying

Vous devez vous connecter pour publier un commentaire.