?? ptplistener.java
字號:
import javax.naming.*;
import javax.jms.*;
public class PTPListener implements MessageListener {
private Connection connection;
private Session session;
private MessageConsumer consumer;
public static void main(String[] args) {
System.out.println ("Listener running");
try {
PTPListener receiver = new PTPListener();
}
catch(Exception ex) {
System.err.println("Exception in PTPListener: " + ex);
}
}
public PTPListener() throws JMSException, NamingException {
try {
Context context = new InitialContext();
ConnectionFactory connectionFactory = (ConnectionFactory)context.lookup("jms/QueueConnectionFactory");
Destination destination = (Destination)context.lookup("jms/firstQueue");
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
consumer = session.createConsumer(destination);
consumer.setMessageListener(this);
connection.start();
}
catch (JMSException ex) {
try {connection.close();} catch(Exception e){}
throw ex;
}
}
public void onMessage(Message message) {
try {
String text;
if (message instanceof TextMessage) {
text = ((TextMessage) message).getText();
}
else {
text = message.toString();
}
System.out.println("Received: " + text);
message.acknowledge();
if (text.equals("Quit")) {
System.out.println("PTPReceiver closing down");
new Thread(new Runnable () {
public void run() {
try {
PTPListener.this.close();
}
catch(JMSException ex) {
System.err.println("Exception in Closer: " + ex);
}
}
}).start();
}
}
catch(JMSException ex) {
System.err.println("Exception in OnMessage: " + ex);
}
}
public void close() throws JMSException {
connection.close();
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -