Comment utiliser Java JMS avec MQseries

une application complète (synchrone) de JMS autonome avec TextMessage.

C'est IBM WebSphere MQ spécifique.

import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

import com.ibm.mq.jms.JMSC;
import com.ibm.mq.jms.MQQueueConnectionFactory;

public class JMSApplicationStandAlone {
    public static void main(String[] args) {
        try {
            /*MQ Configuration*/
            MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
            mqQueueConnectionFactory.setHostName("localhost");
            mqQueueConnectionFactory.setChannel("MQ.CHANNEL");//communications link
            mqQueueConnectionFactory.setPort(1416);
            mqQueueConnectionFactory.setQueueManager("QUEUE.MGR");//service provider 
            mqQueueConnectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);

            /*Create Connection */
            QueueConnection queueConnection = mqQueueConnectionFactory.createQueueConnection();
            queueConnection.start();

            /*Create session */
            QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            /*Create response queue */
            Queue queue = queueSession.createQueue("QUEUE.RESPONSE");


            /*Create text message */
            TextMessage textMessage = queueSession.createTextMessage("put some message here");
            textMessage.setJMSReplyTo(queue);
            textMessage.setJMSType("mcd://xmlns");//message type
            textMessage.setJMSExpiration(2*1000);//message expiration
            textMessage.setJMSDeliveryMode(DeliveryMode.PERSISTENT); //message delivery mode either persistent or non-persistemnt

            /*Create sender queue */
            QueueSender queueSender = queueSession.createSender(queueSession.createQueue("QUEUE.REQEST"));
            queueSender.setTimeToLive(2*1000);
            queueSender.send(textMessage);

            /*After sending a message we get message id */
            System.out.println("after sending a message we get message id "+ textMessage.getJMSMessageID());
            String jmsCorrelationID = " JMSCorrelationID = '" + textMessage.getJMSMessageID() + "'";


            /*Within the session we have to create queue reciver */
            QueueReceiver queueReceiver = queueSession.createReceiver(queue,jmsCorrelationID);


            /*Receive the message from*/
            Message message = queueReceiver.receive(60*1000);
            String responseMsg = ((TextMessage) message).getText();

            queueSender.close();
            queueReceiver.close();
            queueSession.close();
            queueConnection.close();


        } catch (JMSException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Note: remplacer les valeurs de configuration

si cela ne vous dérange pas d'écrire du code spécifique à WMQ, alors vous pouvez faire

MQConnectionFactory cf = new MQConnectionFactory();
cf.setHostName(HOSTNAME);
cf.setPort(PORT);
cf.setChannel(CHANNEL);
cf.setQueueManager(QMNAME);
cf.setTransportType(WMQConstants.WMQ_CM_CLIENT);

d'habitude des ressources JMS

Connection c = cf.createConnection();
Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue q = s.createQueue("myQueue"); // replace with real queue name
MessageProducer p = s.createProducer(q);

et enfin créer et envoyer un message

Message m = s.createTextMessage("Hello, World!);
p.send(m);

(j'ai tapé ça sur le dessus de ma tête donc je ne peux pas exclure une faute de frappe, mais c'est fondamentalement correct). Si vous êtes vraiment censé utiliser 'pure JMS' - c'est-à - dire sans objet spécifique à un fournisseur-alors vous devez lier un objet MQConnectionFactory dans JNDI (jetez un oeil à JMSAdmin l'outil, il est dans le docs) puis chercher à partir de votre application, i.e.

InitialContext ic = new InitialContext(); // or as appropraite
ConnectionFactory cf = (ConnectionFactory)ic.lookup("myMQfactory"); // replace with JNDI name

typiquement avec JMS vous définiriez le QueueConnectionFactory dans votre conteneur via n'importe quel mécanisme de configuration qu'il rend disponible, puis l'ajouter au registre JNDI du conteneur. Chaque conteneur aurait ses propres méthodes pour faire cela (c.-à-d. Tomcat versus WebSphere).

si vous voulez renoncer à JNDI, vous pouvez créer une instance de com.ibm.mq.jms.MQQueueConnectionFactory directement et mettez les propriétés hostname, port, quaemanager et channel dessus. Vous pouvez alors utiliser cet objet comme vous le feriez exemple javax.jms.QueueConnectionFactory depuis qu'il implémente.

je ne peux pas vous enseigner JMS dans un seul post, mais je peux vous diriger vers les ressources que j'ai utilisé pour apprendre moi-même:

1. O'Reilly Java Message Service livre
2. IBM Developerworks JMS Tutorial (plus MQSeries/Websphere MQ spécifique)
3. the Spring framework peut vous aider à utiliser JMS plus efficacement, surtout si vous développez une application autonome en dehors d'un serveur d'application J2EE: Message Java De Printemps Le Service de documentation

C'est assez commun. Ici en sont quelques exemples.