import javax.naming.*;
import javax.jms.*;
QueueConnectionFactory queueConnectionFactory;
Context messaging = new InitialContext();//第一步
queueConnectionFactory = (QueueConnectionFactory)//获取连接工厂
messaging.lookup(""QueueConnectionFactory"");
Queue queue;
queue = (Queue)messaging.lookup(""theQueue"");//获取queue
Topic topic;
topic =(Topic)messaging.lookup(""theTopic"");//获取topic
JMSContext context = connectionFactory.createContext();//创建个上下文
try (JMSContext context =
connectionFactory.createContext();)
{
JMSProducer producer = context.createProducer();
context.createProducer().send(dest, message);//创建消费者或生产者,发送消息
TextMessage message = context.createTextMessage();
message.setText(msg_text);
// msg_text is a String
context.createProducer().send(message);
Message m = consumer.receive();
if (m instanceof TextMessage) {
String message = m.getBody(String.class);
System.out.println(""Reading message: "" + message);
} else {
// Handle error or process another message type
}//创建消息
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。