大家看这段代码吧,提示错误一样,但对您好看一些!!
import java.io.*;
import javax.jms.*;
import javax.naming.*;public class TPublisher { public static void main(String[] args) { new TPublisher().publish();
}
public void publish() { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); try {
//Prompt for JNDI names
String factoryName = "sqm6/jms/jndi";
String topicName="sqmtopic/jms/jndi"; //Look up administered objects
java.util.Hashtable ht = new java.util.Hashtable();
ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
ht.put(Context.PROVIDER_URL,"t3://localhost:7001");
InitialContext initContext = new InitialContext(ht);
TopicConnectionFactory factory =
(TopicConnectionFactory) initContext.lookup(factoryName);
Topic topic = (Topic) initContext.lookup(topicName);
initContext.close(); //Create JMS objects
TopicConnection connection = factory.createTopicConnection();
TopicSession session =
connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicPublisher publisher = session.createPublisher(topic); //Send messages
String messageText = null;
while (true) {
System.out.println("Enter message to send or 'quit':");
messageText = reader.readLine();
if ("quit".equals(messageText))
break;
TextMessage message = session.createTextMessage(messageText);
publisher.publish(message);
} //Exit
System.out.println("Exiting...");
reader.close();
connection.close();
System.out.println("Goodbye!"); } catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}
import java.io.*;
import javax.jms.*;
import javax.naming.*;public class TPublisher { public static void main(String[] args) { new TPublisher().publish();
}
public void publish() { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); try {
//Prompt for JNDI names
String factoryName = "sqm6/jms/jndi";
String topicName="sqmtopic/jms/jndi"; //Look up administered objects
java.util.Hashtable ht = new java.util.Hashtable();
ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
ht.put(Context.PROVIDER_URL,"t3://localhost:7001");
InitialContext initContext = new InitialContext(ht);
TopicConnectionFactory factory =
(TopicConnectionFactory) initContext.lookup(factoryName);
Topic topic = (Topic) initContext.lookup(topicName);
initContext.close(); //Create JMS objects
TopicConnection connection = factory.createTopicConnection();
TopicSession session =
connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicPublisher publisher = session.createPublisher(topic); //Send messages
String messageText = null;
while (true) {
System.out.println("Enter message to send or 'quit':");
messageText = reader.readLine();
if ("quit".equals(messageText))
break;
TextMessage message = session.createTextMessage(messageText);
publisher.publish(message);
} //Exit
System.out.println("Exiting...");
reader.close();
connection.close();
System.out.println("Goodbye!"); } catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}
解决方案 »
- 用jquery ajax方法传输中文,处理乱码的问题
- 一个很简单的问题,进来就给分
- 请教关于jquery的插件datagrid的几个问题,
- xfire客户端问题!!!非常急!!在线等!!!
- 敏捷之源JAVA开源项目大全速查下载(送分)
- JSP+Servlet+JavaBean开发,数据库用Oracle,在Internet上发布,服务器的硬件配置?
- 两次实例化的结果
- 我怎么把2个字符串合并成一个字符串?
- 有两个关于Weblogic和Tomcat的问题求教
- 如何将Java中Date类型的对象插入到Mysql数据库中呢?
- 关于Tomcat的ROOT的疑问
- 我用JB9写一个上传文件的STRUTS程序,但是总是报指针为空的错误,谢谢各位帮我看看
(TopicConnectionFactory) initContext.lookup(factoryName);
Topic topic = (Topic) initContext.lookup(topicName); initContext.close();
//程序在使用完,不能立即把Context关掉。也许就是这里的错。如果不是,你再看看你的工程里的配置文件是否和你的WEBLOGIC里的配置是否一致。