JMS连接MQ出错

还有刚才你贴的代码中没有包括创建MQ连接的部分，和连接参数有可能有关系。收起

你这种做法我没用过，之前是直接引用IBM的jar包访问MQ的。
注意以下两点：环境变量中是否设置了MQ的lib目录、版本是否一致（包括32位或64位）。收起

回复 3# liushaoyi
spring jms配置：

               
               
               
               
       

       
               
       

       
               
               
               
       

       
                        class="org.springframework.jms.listener.DefaultMessageListenerContainer">
               
               
               
                       
               
               
       
java代码：
    package com.upay.mq;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Repository;

@Repository
public class JMSSender{
       
       
       
        /**
     * jms模板，封装链接工厂、队列、消息生产者
     */
        @Autowired
    private JmsTemplate jmsTemplate;

       
         /**
     * 发送消息
     *
     * @param msg消息
     */
    public void showResult(String msg)
    {
        // Text消息
        MessageCreator messageCreator = createTxtMsg(msg);
        jmsTemplate.send(messageCreator);
        // Map消息
        messageCreator = createMapMsg(msg);
        jmsTemplate.send(messageCreator);
    }
   
    /**
     * 创建text消息
     *
     * @param msg 消息
     * @return message
     */
    private MessageCreator createTxtMsg(final String msg)
    {
        return new MessageCreator()
        {

            public Message createMessage(Session session) throws JMSException
            {
                TextMessage textMessage = session.createTextMessage();
                textMessage.setText(msg);
                return textMessage;
            }

        };
    }

    /**
     * 创建map消息
     *
     * @param msg消息
     * @return message
     */
    private MessageCreator createMapMsg(final String msg)
    {
        return new MessageCreator()
        {

            public Message createMessage(Session session) throws JMSException
            {
                MapMessage mapMessage = session.createMapMessage();
                mapMessage.setString("map", "javax.jms.MapMessage");
                mapMessage.setString("map1", msg);
                return mapMessage;
            }
        };
    }




}收起

还有可以把你连接MQ的代码贴出来吗？收起

你网上搜的这个解决方法莫名其妙，要删文件也肯定不能删除安装目录下的，
你要说一下你的环境情况，java程序引用的jar包版本是不是和需要连接的MQ是否一致。
还有环境变量是不是设置正确了。收起