ptpsender.java

来自「采用Java开发的基于MQ技术的通讯程序」· Java 代码 · 共 48 行

import java.util.*;
import javax.jms.*;
import javax.naming.directory.*;
import javax.naming.*;
import com.ibm.mq.jms.MQQueueConnectionFactory;
//import com.ibm.mq.*;


public class PtpSender {
public static void main(String[] args) {

// Creating a QueueConnectionFactory without JNDI

MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
((MQQueueConnectionFactory) factory).setQueueManager("qm0171");

// Create a QueueConnection from the QueueConnectionFactory
QueueConnection connection = factory.createQueueConnection();

try {
// IMPORTANT: Receive calls will be blocked if the connection is 
// not explicitly started, so make sure that we do so!
connection.start();

// We now create a QueueSession from the connection. session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
//Use the session to create the queue object, supplying the required MQ-specific parameter

Session session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("lq_c_real_0171");

//create QueueSender
QueueSender queueSender=session.createSender(queue);

//create a msg
message=session.createTextMessage(s);

//send the message
queueSender.send(message);

System.out.println("\n The Message has been sent");

queueConnection.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}