springboot集成weblogic的jms源码.zip

package com.sgm.ici.personalization.ms; import java.util.Properties; import javax.jms.ConnectionFactory; import javax.jms.Destination; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.listener.DefaultMessageListenerContainer; import org.springframework.jndi.JndiObjectFactoryBean; import org.springframework.jndi.JndiTemplate; import com.sgm.ici.personalization.ms.service.util.MyMessageListener; @Configuration public class JmsConfiguration{ private String userName = "cmat"; private String connectionFactory = "jms/IDMTopicConnectionFactory"; private String password = "Pass1234"; private String topic = "jms/IDMICITopic"; private String url = "t3://10.203.25.58:7003"; @Autowired private MyMessageListener myMessageListener; @Bean(name = "weblogicJms") public JndiTemplate weblogicJms(){ Properties props = new Properties(); props.setProperty("java.naming.factory.initial", "weblogic.jndi.WLInitialContextFactory"); props.setProperty("java.naming.provider.url", url ); props.setProperty("java.naming.security.principal", userName); props.setProperty("java.naming.security.credentials",password); JndiTemplate jmsJndiTemplate = new JndiTemplate(); jmsJndiTemplate.setEnvironment(props); return jmsJndiTemplate; } @Bean(name = "jmsConnectionFactory") public JndiObjectFactoryBean jmsConnectionFactory(){ JndiObjectFactoryBean jndiObjectFactoryBean = new JndiObjectFactoryBean(); jndiObjectFactoryBean.setJndiName(connectionFactory); jndiObjectFactoryBean.setJndiTemplate(weblogicJms()); return jndiObjectFactoryBean; } @Bean(name = "jmsDestination") public JndiObjectFactoryBean jmsDestination(){ JndiObjectFactoryBean jmsDestination = new JndiObjectFactoryBean(); jmsDestination.setJndiName(topic); jmsDestination.setJndiTemplate(weblogicJms()); return jmsDestination; } @Bean(name = "listenerTopic") @ConditionalOnMissingBean public DefaultMessageListenerContainer listenerTopic(){ DefaultMessageListenerContainer listener = new DefaultMessageListenerContainer(); listener.setConnectionFactory((ConnectionFactory) jmsConnectionFactory().getObject()); listener.setDestination((Destination) jmsDestination().getObject()); listener.setAutoStartup(true); listener.setPubSubDomain(true); listener.setMessageListener(myMessageListener); return listener; } @Bean(name = "jmsTemplate" ) @ConditionalOnMissingBean public JmsTemplate getJmsTemplate(){ JmsTemplate jmsTemplate = new JmsTemplate(); jmsTemplate.setConnectionFactory((ConnectionFactory) jmsConnectionFactory().getObject()); jmsTemplate.setDefaultDestination((Destination) jmsDestination().getObject()); jmsTemplate.setPubSubDomain(true); jmsTemplate.setExplicitQosEnabled(true); return jmsTemplate; } }