SSM项目整合RabbitMQ

SSMRabbitMQ

    org.springframework.amqp
    spring-rabbit
    2.0.1.RELEASE
	
    
        
            spring-context
            org.springframework
        
    

RabbitMQ的配置写完要记得天加进主配置

public class MessageConsumer implements MessageListener {
    @Override
    public void onMessage(Message message) {
        try {
            String messages = new String(message.getBody(), "UTF-8");
            Thread.sleep(5000);
            System.out.println(messages);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

@Component
public class MessageProvider {

    @Resource(name = "amqpTemplate")
    private AmqpTemplate amqpTemplate;

    public void sendMessage(Object message) throws IOException {
        amqpTemplate.convertAndSend("Routingkey", message);
    }
}

这个时候修改spring-rabbitmq.xml文件

			↑
		  替换成
			↓

这是因为spring命名空间配置版本不正确：
spring-beans-3.0.xsd --> spring-beans.xsd
spring-rabbit-1.2.xsd --> spring-rabbit.xsd