springcloud bus rabbitmq 分布式队列

/* * Project: SpringCloudDemo-BUS-RabbitMQ * * File Created at 2017年2月13日 * * Copyright 2016 CMCC Corporation Limited. * All rights reserved. * * This software is the confidential and proprietary information of * ZYHY Company. ("Confidential Information"). You shall not * disclose such Confidential Information and shall use it only in * accordance with the terms of the license. */ package com.curiousby.cn; import java.util.Date; import org.springframework.amqp.core.Queue; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.context.annotation.Bean; import org.springframework.messaging.handler.annotation.Payload; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.stereotype.Component; /** * @Type RabbitMQProcess.java * @Desc * @author hadoop * @date 2017年2月13日 下午3:55:46 * @version */ @Component @RabbitListener(queues = "mqqueue") @EnableScheduling public class Reciever { @Bean public Sender mySender() { return new Sender(); } @Bean public Queue fooQueue() { return new Queue("mqqueue"); } @RabbitHandler public void process(@Payload String foo) { System.out.println(new Date() + "==== :" + foo); } } /** * Revision history * ------------------------------------------------------------------------- * * Date Author Note * ------------------------------------------------------------------------- * 2017年2月13日 hadoop creat */