?? ptpsender.java
字號(hào):
import javax.naming.*;
import javax.jms.*;
public class PTPSender {
private Connection connection;
private Session session;
private MessageProducer producer;
public static void main(String[] args) {
PTPSender sender = null;
try {
sender = new PTPSender();
System.out.println ("Sending message Hello World");
sender.sendMessage("Hello World");
}
catch(Exception ex) {
System.err.println("Exception in PTPSender: " + ex);
}
finally {
try {sender.close();} catch(Exception ex){}
}
}
public PTPSender() throws JMSException, NamingException {
Context context = new InitialContext();
ConnectionFactory connectionFactory = (ConnectionFactory)context.lookup("jms/QueueConnectionFactory");
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = (Destination)context.lookup("jms/firstQueue");
producer = session.createProducer(destination);
}
public void sendMessage(String msg) throws JMSException {
TextMessage message = session.createTextMessage();
message.setText(msg);
producer.send(message);
}
public void close() throws JMSException {
producer.close();
session.close();
connection.close();
}
}
?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -