2016-07-20 175 views
0

我使用spring jms連接到Websphere MQ。問題連接到Websphere Mq

Connection names (all as an example): hostname: <Websphere ip address> http://localhost:9043 
given hostname 12.123.0.12 

In Resources->JMS->Queue connection Factories 
name: MQDemo 
JNDI name: MQDemo 

2 Queues: 
name: MQ.T11.UPDATE.REQUEST 
JNDI name: jms/MQ.T11.UPDATE.REQUEST 

name: MQ.T11.INQUIRY.REPLY 
JNDI name: jms/MQ.T11.UPDATE.REQUEST 

DemoMain.java

在主要方法:

ApplicationContext ctx = new ClassPathXmlApplicationContext("app-context.xml"); 
    // get bean from context 
    JmsMessageSender jmsMessageSender = (JmsMessageSender)ctx.getBean("jmsMessageSender"); 
    // send to default destination 
     jmsMessageSender.send(); 

JMSMessageSender.java

package name: com.java.geek 

@Autowired 
    private JmsTemplate jmsTemplate; 


    /** 
    * send text to default destination 
    * @param text 
    */ 
    @Cacheable("message") 
    public void send() { 
     System.out.println("in send"); 
     jmsTemplate.send(new MessageCreator() { 
     @Override 
     public Message createMessage(Session session)throws JMSException { 

      System.out.println("in create message"); 
     Message message = (Message) session.createTextMessage("Hello JMS"); 
     return message; 
     } 
     }); 

    } 

    public JmsTemplate getJmsTemplate() 
    { 
     return jmsTemplate; 
    } 

    public void setJmsTemplate(JmsTemplate jmsTemplate) 
    { 
     this.jmsTemplate = jmsTemplate; 
    } 

APP-context.xml中

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:beans="http://www.springframework.org/schema/beans" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xsi:schemaLocation=" 
    http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans.xsd 
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context.xsd"> 


    <context:component-scan base-package="com.java.geek" /> 
<bean id="amqConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> 
    <property name="hostName"> 
     <value>http://localhost:9043</value> 
    </property> 
    <property name="port"> 
     <value>1415</value> 
    </property> 
    <property name="queueManager"> 
     <value>MQDemo</value> 
    </property> 
    <property name="transportType"> 
     <value>1</value> 
    </property> 
</bean> 

    <!-- Pooled Spring connection factory --> 
    <bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean" lazy-init="true"> 
     <property name="MQDemo" value="java:comp/env/jms/MQDemo" /> 
     <property name="lookupOnStartup" value="false"/> 
      <property name="cache" value="true" /> 
      <property name="proxyInterface" value="javax.jms.QueueConnectionFactory"/> 
     <constructor-arg ref="amqConnectionFactory" /> 
    </bean> 


    <!-- JmsTemplate Definition --> 
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 
     <property name="connectionFactory"><ref bean="amqConnectionFactory" /> </property> 
     <property name="pubSubDomain"><value>false</value></property> 
     <!-- <property name="defaultDestination"><ref bean="senderQueue" /></property> --> 
    </bean> 

    <!-- ======================================================= --> 
    <!-- JMS Send, define default destination and JmsTemplate --> 
    <!-- ======================================================= --> 

    <!-- Default Destination Queue Definition --> 
    <bean id="senderQueue" class="com.ibm.mq.jms.MQQueue"> 
     <constructor-arg value="TEST" /> 
     <property name="MQ.T11.UPDATE.REQUEST" value="java:comp/env/jms/MQ.T11.UPDATE.REQUEST" /> 
    </bean> 
    <bean id="jmsMessageSender" class="com.java.geek.JmsMessageSender"> 
     <property name="jmsTemplate"><ref bean="SenderJMSTemplate"/></property>  
    </bean> 

</beans> 

我得到一個錯誤,

"Error creating bean with name 'jmsMessageSender': Injection of autowired dependencies failed; 
nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private org.springframework.jms.core.JmsTemplate com.shengwang.demo.JmsMessageSender.jmsTemplate; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'connectionFactory' defined in class path resource [app-context.xml]: 
Cannot resolve reference to bean 'amqConnectionFactory' while setting constructor argument; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'amqConnectionFactory' defined in class path resource [app-context.xml]: Instantiation of bean failed; 
nested exception is org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [com.ibm.mq.jms.MQQueueConnectionFactory]: Constructor threw exception; 
nested exception is java.lang.NoClassDefFoundError: com/ibm/disthub2/impl/client/SessionConfig 

和其他錯誤,SAXException

我無法連接到Websphere MQ。請提出代碼中的錯誤。

回答

0

我想說,您需要檢查MQ客戶端是否正確安裝在您的代碼正在運行的框中。複製WMQ jar並期望它正常工作是一個常見的錯誤。您的代碼將生成,但您將從MQ類中正確獲取這種NoClassDefFound。儘管您可能會在最終追逐正在運行的IBM安裝中的每個jar,但它不會受到支持(請參閱http://www-01.ibm.com/support/docview.wss?uid=swg21376217

獲取WMQ安裝介質並在您使用的計算機上運行安裝。然後運行IBM的「入門」來確保它可以正常運行。

0

NoClassDefFoundError表明編譯器能夠找到該類,但運行時進程沒有。

我建議你的運行時類路徑中可能缺少一些東西。嘗試將它與您的構建/編譯類路徑進行比較。