QueueConfig.java 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. //package com.fdkankan.rabbitmq.config;
  2. //
  3. //import org.springframework.context.annotation.Configuration;
  4. //
  5. //@Configuration
  6. //public class QueueConfig {
  7. //
  8. // /**
  9. // * durable="true" 持久化 rabbitmq重启的时候不需要创建新的队列
  10. // * exclusive 表示该消息队列是否只在当前connection生效,默认是false
  11. // * auto-delete 表示消息队列没有在使用时将被自动删除 默认是false
  12. // */
  13. ////
  14. //// @Bean(name = RabbitMQConstant.QUEUE_EASY)
  15. //// public Queue easyQueue() {
  16. //// return new Queue(RabbitMQConstant.QUEUE_EASY, true, false, false);
  17. //// }
  18. //
  19. //// @Bean(name = RabbitMQConstant.QUEUE_WORK)
  20. //// public Queue workQueue() {
  21. //// return new Queue(RabbitMQConstant.QUEUE_WORK, true, false, false);
  22. //// }
  23. //
  24. //// @Bean(name = RabbitMQConstant.QUEUE_TOPIC_FIRST)
  25. //// public Queue topicQueue() {
  26. //// return new Queue(RabbitMQConstant.QUEUE_TOPIC_FIRST, true, false, false);
  27. //// }
  28. ////
  29. //// @Bean(name = RabbitMQConstant.QUEUE_TOPIC_SECOND)
  30. //// public Queue topicQueueSecond() {
  31. //// return new Queue(RabbitMQConstant.QUEUE_TOPIC_SECOND, true, false, false);
  32. //// }
  33. ////
  34. //// @Bean(name = RabbitMQConstant.QUEUE_FANOUT)
  35. //// public Queue fanoutQueue() {
  36. //// return new Queue(RabbitMQConstant.QUEUE_FANOUT, true, false, false);
  37. //// }
  38. ////
  39. //// @Bean(name = RabbitMQConstant.QUEUE_FANOUT_SECOND)
  40. //// public Queue fanoutQueueSecond() {
  41. //// return new Queue(RabbitMQConstant.QUEUE_FANOUT_SECOND, true, false, false);
  42. //// }
  43. //
  44. //
  45. //}