spring jms

maven

<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jms</artifactId>
		</dependency>

spring

<?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:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:jms="http://www.springframework.org/schema/jms" xmlns:amq="http://activemq.apache.org/schema/core"
	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
	http://www.springframework.org/schema/jms 
	http://www.springframework.org/schema/jms/spring-jms.xsd
	http://activemq.apache.org/schema/core 
	http://activemq.apache.org/schema/core/activemq-core.xsd">

<!-- 通知发送的 配置  -->
	<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
		<property name="environment">
			<props>
				<prop key="connectionFactoryNames">${connectionFactoryNames}
				</prop>
				<prop key="java.naming.factory.initial">${java.naming.factory.initial}</prop>
				<prop key="java.naming.provider.url">${java.naming.provider.url}</prop>
				<prop key="java.naming.security.principal">${java.naming.security.principal}</prop>
				<prop key="java.naming.security.credentials">${java.naming.security.credentials}</prop>
			</props>
		</property>
	</bean>

	<bean id="jndiQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
		<property name="jndiTemplate" ref="jndiTemplate" />
		<property name="jndiName" value="${connectionFactoryNames}" />
	</bean>

	<bean id="queueConnectionFactory"
		class="org.springframework.jms.connection.CachingConnectionFactory">
		<property name="targetConnectionFactory" ref="jndiQueueConnectionFactory" />
		<property name="sessionCacheSize" value="1" />
	</bean>

	<bean id="queueDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
		<property name="jndiTemplate" ref="jndiTemplate" />
		<property name="jndiName" value="${connectionFactoryNames}" />
	</bean>

	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="queueConnectionFactory" />
		<property name="defaultDestinationName" value="${connectionFactoryNames}" />
		<property name="pubSubDomain" value="false" />
	</bean>

	<!-- Counter for consumer to increment and test to verify count -->
	<bean id="counter" class="java.util.concurrent.atomic.AtomicInteger" />

</beans>

java

import javax.jms.JMSException;
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.Service;
@Service
public class JMSSenderImpl implements JMSSender{
	
	@Autowired
	public JmsTemplate jmsTemplate = null;
	public String queueName = null;
	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	public void setQueueName(String queueName) {
		this.queueName = "";
	}
	public void sendNotice(final String message, final Integer id) {
		MessageCreator msg = new MessageCreator() {

			public Message createMessage(Session session) throws JMSException {
				TextMessage msg = session.createTextMessage(message);
				msg.setIntProperty("messageCount", id);
				return msg;
			}
		};
		jmsTemplate.send("msg", msg);
		
		
	}
}