大家好,我参照http://qjyong.javaeye.com/blog/215171
这个文章,一步步的把代码粘贴到工作空间,
之后,
在public User receiveMessage() {
// 参数为Destination的JNDI名字去掉前面的模式类型标识
MapMessage msg = (MapMessage) jmsTemplate.receive("registerUserTopic");
User user = new User(); try {
user.setId(msg.getInt("id"));
user.setUsername(msg.getString("username"));
user.setPassword(msg.getString("password"));
user.setEmail(msg.getString("email"));
} catch (JMSException e) {
e.printStackTrace();
} return user;
}
中,提示msg.getInt("id")空指针,
在消息发送的时候,没有发生异常,public void sendMessage(final User user){
//调用模板的send来发送消息
jmsTemplate.send(new MessageCreator(){
public Message createMessage(Session session) throws JMSException {
//构造一个要发送的消息
MapMessage message = session.createMapMessage();
message.setInt("id", user.getId());
message.setString("username", user.getUsername());
message.setString("password", user.getPassword());
message.setString("email", user.getEmail());
System.out.println("send success!!");
return message;
}
});。请各位帮帮忙,大概问题出在哪了。。
这个文章,一步步的把代码粘贴到工作空间,
之后,
在public User receiveMessage() {
// 参数为Destination的JNDI名字去掉前面的模式类型标识
MapMessage msg = (MapMessage) jmsTemplate.receive("registerUserTopic");
User user = new User(); try {
user.setId(msg.getInt("id"));
user.setUsername(msg.getString("username"));
user.setPassword(msg.getString("password"));
user.setEmail(msg.getString("email"));
} catch (JMSException e) {
e.printStackTrace();
} return user;
}
中,提示msg.getInt("id")空指针,
在消息发送的时候,没有发生异常,public void sendMessage(final User user){
//调用模板的send来发送消息
jmsTemplate.send(new MessageCreator(){
public Message createMessage(Session session) throws JMSException {
//构造一个要发送的消息
MapMessage message = session.createMapMessage();
message.setInt("id", user.getId());
message.setString("username", user.getUsername());
message.setString("password", user.getPassword());
message.setString("email", user.getEmail());
System.out.println("send success!!");
return message;
}
});。请各位帮帮忙,大概问题出在哪了。。
怀疑:1.没法出去
2.没监听到……
……试试看去jboss上看看消息在不在队列。