IBM MQ Auditeur de Message

Bien qu'il y est un WMQ API Java comme indiqué par les précédents intervenants, WMQ prend en charge JMS ainsi donc, voici quelques ressources pour vous aider à démarrer.

Prendre un coup d'oeil à cet article: IBM WebSphere Développeur Revue Technique: l'Exécution d'une application Java autonome sur WebSphere MQ V6.0

Aussi, si vous avez installé le plein WMQ client et pas juste attrapé les pots, puis vous aurez beaucoup d'exemples de code installé. Par défaut, ces vivront dans C:\Program Files\IBM\WebSphere MQ\tools\jms ou /opt/mqm/samp en fonction de votre plate-forme.

Si vous avez besoin de la WMQ Client installer des médias, obtenir ici. Notez que c'est la WMQ v7 client et non le v6 client. Il est compatible avec la v6 QMgr mais depuis la v6 est en fin de vie à compter de septembre 2011, vous devez être en train de faire un nouvel aménagement sur la v7 client et, si possible, une v7 QMgr. Il y a beaucoup de fonctions et les performances des améliorations disponibles si les deux côtés sont v7.

Vous pouvez obtenir le manuel du produit ici si vous en avez besoin.

Enfin, s'il vous plaît être sûr que lorsque vous obtenez un JMS exception à imprimer liés exception. Ce n'est pas un WMQ chose, c'est plutôt un JMS chose. Soleil en un multi-niveau de la structure de données JMS exceptions et, le plus intéressant, les pièces sont souvent imbriquées. Ce n'est pas une grosse affaire et peut être mis en œuvre en quelques lignes:

try {
  .
  . code that might throw a JMSException
  .
} catch (JMSException je) {
  System.err.println("caught "+je);
  Exception e = je.getLinkedException();
  if (e != null) {
    System.err.println("linked exception: "+e);
  } else {
    System.err.println("No linked exception found.");
  }
}

Cela permet de déterminer la différence entre un JMS erreur par rapport à une erreur de transport. Par exemple JMS de sécurité de l'erreur peut être une WMQ 2035, ou il peut être la JSSE de configuration, ou l'application pourrait ne pas avoir accès à quelque chose dans le système de fichiers. Un seul de ces est la peine de dépenser beaucoup de temps à creuser par le biais de la WMQ les journaux d'erreur et seulement par l'impression de l'exception liée serez-vous capable de dire si c'est celui-là.

OriginalL'auteur T.Rob

Juste au cas où quelqu'un sera google stackoverflow pour MQ Auditeur comme je l'ai fait...
Il peut-être pas la réponse en raison de JMS réalisation, mais c'est ce que je cherchais.
Quelque chose comme ceci:

MQQueueConnectionFactory cf = new MQQueueConnectionFactory();
MQQueueConnection conn = (MQQueueConnection)cf.createQueueConnection();
MQQueueSession session = (MQQueueSession)conn.createSession(false, 1);
Queue queue = session.createQueue("QUEUE");
MQQueueReceiver receiver = (MQQueueReceiver)session.createReceiver(queue);
receiver.setMessageListener(new YourListener());
conn.start();

YourListener doit implémenter l'interface MessageListener et vous recevrez des messages dans onMessage(Message msg) de la méthode.

OriginalL'auteur Konstantin Kuznetsov

Un point important dans les réponses: JMS fournit MessageListener, une classe qui vous permet de recevoir des messages asynchrones des rappels.

L'API native a pas d'équivalent! Vous devez appeler à plusieurs reprises get(...) appropriées.

OriginalL'auteur Air

Bonjour, voici l'exemple de travail de l'auditeur de message avec IBM MQ. J'ai utilisé ici le printemps pour créer des haricots etc...

package queue.app;
import javax.annotation.PostConstruct;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.ibm.mq.jms.MQQueue;
import com.ibm.mq.jms.MQQueueConnectionFactory;
import com.ibm.msg.client.wmq.WMQConstants;
@Component
public class QueueConsumer implements MessageListener{
private Logger logger = Logger.getLogger(getClass());
MQQueueConnectionFactory qcf = new MQQueueConnectionFactory();
QueueConnection qc;
Queue queue;
QueueSession queueSession;
QueueReceiver qr;
@Value("${jms.hostName}")
String jmsHost;
@Value("${jms.port}")
String jmsPort;
@Value("${jms.queue.name}")
String QUEUE_NAME;
@Value("${jms.queueManager}")
String jmsQueueMgr;
@Value("${jms.username}")
String jmsUserName;
@Value("${jms.channel}")
String jmsChannel;
@PostConstruct
public void init() throws Exception{
qcf.setHostName (jmsHost);
qcf.setPort (Integer.parseInt(jmsPort));
qcf.setQueueManager (jmsQueueMgr);
qcf.setChannel (jmsChannel);
qcf.setTransportType (WMQConstants.WMQ_CM_CLIENT);
qc = qcf.createQueueConnection ();
queue = new MQQueue(QUEUE_NAME);
qc.createQueueSession (false, Session.AUTO_ACKNOWLEDGE);
queueSession = qc.createQueueSession (false, Session.AUTO_ACKNOWLEDGE);
qr = queueSession.createReceiver(queue);
qr.setMessageListener(this);
qc.start();
}
@Override
public void onMessage(Message message) {
logger.info("Inside On Message...");
long t1 = System.currentTimeMillis();
logger.info("Message consumed at ...."+t1);
try{
if(message instanceof TextMessage) {
logger.info("String message recieved >> "+((TextMessage) message).getText());
}
}catch(Exception e){
e.printStackTrace();
}
}
}

Ci-dessous sont les dépendances que j'ai..

<dependency>
<groupId>com.sun.messaging.mq</groupId>
<artifactId>fscontext</artifactId>
<version>4.2</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>jms</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>3.2.17.RELEASE</version>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>com.ibm.mq</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>com.ibm.mq.allclient</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>com.ibm.mq.jmqi</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>com.ibm.mqjms</artifactId>
<version>1.0</version>
</dependency>

OriginalL'auteur Sunil Chauraha